如下阻塞隊列+線程的代碼，很常見，當(dāng)服務(wù)停止時，如何停止被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) {

            }
        }
    }
});

方法是當(dāng)服務(wù)停止時，觸發(fā)一個操作，給blockingQueue放一個特殊的元素，如上面，傳一個值為-1的元素代表停止事件，線程取到這個特殊元素時就跳出循環(huán)：

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) {

            }
        }
    }
});