如何停止被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) {
} } } });

• « 上一篇：Stream流中将集合转成map
• » 下一篇：内存函数细节及实现