典型的生产者消费者模型。
了解j5的并发库，那个并发库中有适合组件实现。
如果不了解，这么来：
创建一个队列，此队列要求线程安全，如果队列为空则消费者阻塞。如果队列达到某个最大值，则阻塞生产者。
队列用，普通的list或实现好的队列包装成线程安全的。
用synchronized同步原方法或代码块。
写一个或n个线程，模拟病人，排队办理业务，往上面的队列中添加数据。
当达到队列的最大容积，阻塞，等待生产者线程取数据。
阻塞：makerLock.wait();//虚拟机会出让线程挂起，其实就是操作系统，保存当前线程在cpu上的运行状态。再出让线程正在使用的cpu资源，占用的内存不会释放。
往队列插入数据的时候，因为不知道是否有消费者处于等待状态，通知消费者：
customerLock.notifyAll();//虚拟机调度消费者线程运行，实际上是操作系统，把保存的消费者线程状态，从新加载到cpu中接着运行。接着运行线程是任意的，取决于不同操作系统的线程调度算法。
消费者线程读取一个数据后，要通知生产者，可以继续，道理同上：
makerLock.notifyAll();
队列中，无数据可读的时候：
customerLock.wait();//原理同上，
最后注意，生产者跟消费者使用了两个不同的对象锁。lock.wait()的使用方法是这样的：
synchronized(lock){
... ...
while(condition == true) {
lock.wait();
}
... ...
Object o = queen.pop();
lock.notifyAll();
}
最后启动n个线程读队列，模拟办理业务的窗口；n个线程写队列，模拟病人排队。
新线程库也有跟老线程库对应的方法，新线程库有线程安全的高效队列。没有上面麻烦，但上面写的是理解新线程数据结构与实现的基础。
package com.zhidao;import java.util.LinkedList;
import java.util.List;
import java.util.Random;
public class TestThread2 {
//缓冲上限
private long bufsize;
//缓冲
private List<String> buf;
public TestThread2() {
bufsize = 5;
buf = new LinkedList<String>();
}
//生产者调用
public void put(String s) {
//模拟生产者跟不上消费者
/*
try {
Thread.sleep(100);
} catch (InterruptedException e) {
}
*/
synchronized(this) {
//超过队列限制就等待
while(buf.size() == bufsize) {
System.out.println("队列已满，生产者:"+Thread.currentThread().getId()+"开始等待。");
try {
this.wait();
} catch (InterruptedException e) {
}
}
buf.add(s);
//通知消费者
this.notifyAll();
}
}
//消费者调用
synchronized public String take() {
//模拟消费者跟不上生产者
try {
Thread.sleep(100);
} catch (InterruptedException e) {
}
String s = null;
synchronized(this) {
while(buf.size() == 0) {
System.out.println("队列为空，消费者:"+Thread.currentThread().getId()+"开始等待。");
try {
this.wait();
} catch (InterruptedException e) {
}
}
//取先放入的元素，并移除
s= buf.get(0);
buf.remove(0);
//通知生产者
this.notifyAll();
}
return s;
}
public static void main(String[] args) {
//自己实现的，安全队列
final TestThread2 tt = new TestThread2();
//生产者
Thread p = new Thread(new Runnable(){
@Override
public void run() {
while(!Thread.currentThread().isInterrupted()) {
Random r = new Random();
tt.put(String.valueOf(r.nextInt(10)));
}
}
});
//消费者
Thread c1 = new Thread(new Runnable(){
@Override
public void run() {
while(!Thread.currentThread().isInterrupted()) {
System.out.println("线程："+Thread.currentThread().getId()+"获取到数据"+tt.take());
}
}
});
Thread c2 = new Thread(new Runnable(){
@Override
public void run() {
while(!Thread.currentThread().isInterrupted()) {
System.out.println("线程："+Thread.currentThread().getId()+"获取到数据"+tt.take());
}
}
});
p.start();
c1.start();
c2.start();
try {
p.join();
c1.join();
c2.join();
} catch (InterruptedException e) {
}
}
}
没原因，就是被驳回了
我这个课题能帮忙么🙏
追答可以的
追问谢谢大神🙏
这管理员应该是跟我有仇