如何停止被BlockingQueue阻塞的线程


如下阻塞队列+线程的代码，很常见，当服务停止时，如何停止被BlockingQueue阻塞的线程？
BlockingQueue<Integer> blockingQueue = new ArrayBlockingQueue(10); final
Thread thread= new Thread(new Runnable() { @Override public void run() { while (
true) { try { Integer el = blockingQueue.take(); System.out.println(el); } catch
(InterruptedException e) { } } } });
方法是当服务停止时，触发一个操作，给blockingQueue放一个特殊的元素，如上面，传一个值为-1的元素代表停止事件，线程取到这个特殊元素时就跳出循环：
final int STOP_CODE = -1; BlockingQueue<Integer> blockingQueue = new
ArrayBlockingQueue(10); final Thread thread = new Thread(new Runnable() {
@Override public void run() { while (true) { try { Integer el = blockingQueue.
take(); // quit loop when receive stop event if (STOP_CODE == el) { break; }
//do something useful System.out.println(el); } catch (InterruptedException e) {
} } } });

技术
下载桌面版
GitHub
Microsoft Store
SourceForge
Gitee
百度网盘（提取码：draw）
云服务器优惠
华为云优惠券
京东云优惠券
腾讯云优惠券
阿里云优惠券
Vultr优惠券
站点信息
问题反馈
邮箱：[email protected]
吐槽一下
QQ群：766591547
关注微信
©2020-2025 ioDraw All rights reserved, Privacy Policy