class MyResource {
private volatile boolean FLAG = true;
private AtomicInteger atomicInteger = new AtomicInteger();
BlockingQueue<String> blockingQueue = null;
public MyResource(BlockingQueue<String> blockingQueue ){
this.blockingQueue=blockingQueue;
}
public void myProducer() {
while (FLAG) {
String data = atomicInteger.incrementAndGet() + "";
boolean result = false;
try {
result = blockingQueue.offer(data, 2L, TimeUnit.SECONDS);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (result) {
System.out.println(Thread.currentThread().getName() + "生产队列" + data + "成功");
} else {
System.out.println(Thread.currentThread().getName() + "生产队列" + data + "失败");
}
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName() + "老板叫停");
}
public void myConsumer() {
while (FLAG){
String result= null;
try {
result = blockingQueue.poll(2L, TimeUnit.SECONDS);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (result == null || result.equalsIgnoreCase("")){
FLAG=false;
System.out.println(Thread.currentThread().getName()+"2s后取不到蛋糕,退出,消费叫停");
return;
}else {
System.out.println(Thread.currentThread().getName()+"消费队列"+result+"成功");
}
}
}
public static void main(String[] args) {
MyResource myResource = new MyResource(new ArrayBlockingQueue<>(10));
new Thread(() -> {
System.out.println(Thread.currentThread().getName()+"生产线程启动");
myResource.myProducer();
}, "producer").start();
new Thread(() -> {
System.out.println(Thread.currentThread().getName()+"消费线程启动");
System.out.println();
System.out.println();
myResource.myConsumer();
}, "comsumer").start();
try {
TimeUnit.SECONDS.sleep(5L);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"5秒钟后,生产叫停");
myResource.FLAG = false;
}
}
生产者消费者阻塞队列
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 见贤思齐焉,见不贤而内自省也。—《论语》 Java5.0 增加了两种新的容器类型,它们是指:Queue 和 Blo...
- 本例参照<<Java编程思想第21章>> 此例为吐司制作过程,一天机器具有三个任务,一个制作吐司,一个给吐司抹黄油...
- 阻塞队列提供了可阻塞的put 和take方法, 以及支持定时的offer和poll方法。如果队列已经满了, 那么p...