public Task getNextTask(BlockingQueue<Task> queue) {
 boolean interrupted = false;
 try {
  while (true) {
   try {
    return queue.take();
   } catch (InterruptedException e) {
    //fianlly中依賴的狀態(tài)標(biāo)記
    interrupted = true;
    // fall through and retry
   }
  }
 } finally {
  if (interrupted)
  //在fianlly中重新標(biāo)記，確保沒有丟失中斷通知
   Thread.currentThread().interrupt();
 }
}

package concurrent;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
 * Created by wanshao
 * Date: 2017/12/18
 * Time: 下午3:42
 **/
public class InterruptExample {
 public static void main(String[] args) throws InterruptedException {
  InterruptTask interruptTask = new InterruptTask();
  ExecutorService executorService = Executors.newSingleThreadExecutor();
  executorService.submit(interruptTask);
  Thread.sleep(100);
  interruptTask.cancel();
  executorService.shutdown();
 }
}
/**
 * 一個(gè)響應(yīng)中斷的任務(wù)
 */
class InterruptTask implements Callable<Integer> {
 private BlockingQueue<Task> queue;
 //保存要被interrupt的線程
 Thread t;
 @Override
 public Integer call() throws InterruptedException {
  System.out.println("start a blocked task");
  try {
   t = Thread.currentThread();
   Thread.currentThread().sleep(50000);
  } catch (InterruptedException e) {
   System.out.println("be interrupted");
   e.printStackTrace();
  }
  return 0;
 }
 public void cancel() {
  System.out.println("cacel a task....");
  //這里直接調(diào)用Thread.currentThread()會(huì)獲取到main線程，而不是線程池里面的線程
  if (!t.isInterrupted()) {
   t.interrupt();
  }
 }
}