当线程阻塞时，在线程上调用的中断不会引发中断异常

Question

编辑：

主要问题：为什么只有一个线程抛出interruptedexception，而两个线程都阻塞在条件上。await

所以下面的代码只是我创建的一个示例。主要的问题是开发一个生产者-消费者实现，在这个实现中，我必须创建一个模拟类，它产生两种线程：客户线程和厨师线程，这两种线程是基于可重入锁进行同步的。在执行一些操作（客户添加订单，厨师执行服务这些订单）后，我调用客户线程上的join以确保所有订单都已处理，然后为了停止库克线程，我调用库克线程上的interrupt以终止它们。但是只有一个线程抛出interruptedexception，第二个线程不抛出。为什么会这样？因为这两个线程都阻塞在等待。

public class InterruptedThread implements Runnable{

    private final Lock lock;
    private final Condition condition;
    private final Queue<Integer> orderQueue;


    public InterruptedThread(Lock lock, Condition condition,Queue<Integer> orderQueue)
    {
        this.lock = lock;
        this.condition = condition;
        this.orderQueue = orderQueue;
    }

    @Override
    public void run() {

        try{
        while(true)
        {
            this.lock.lockInterruptibly();
            while(orderQueue.size() == 0 && !Thread.currentThread().isInterrupted())
            {
                   System.out.println("Inside blocking wait" + Thread.currentThread().getName());
                   condition.await();
            }

            int i = orderQueue.poll().intValue();
            System.out.println("Value read:" + i + "by thread" + Thread.currentThread().getName());
            this.lock.unlock();


        }
        }
        catch(InterruptedException ex)
        {
            System.out.println("Interrupted exception" + Thread.currentThread().getName());
            this.condition.signalAll();
            Thread.currentThread().interrupt();

        }

    }

}

public class ExplicitLockCondition {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        // TODO code application logic here

        Queue<Integer> orderQueue = new LinkedList<>();
        Lock lock = new ReentrantLock();
        Condition testCondition = lock.newCondition();

        Thread[] ths = new Thread[2];
        for(int i=0; i<ths.length;i++)
        {
            ths[i] = new Thread(new InterruptedThread(lock, testCondition,orderQueue));
            ths[i].start();
        }

        lock.lock();

        orderQueue.add(1);
        lock.unlock();

        lock.lock();
        orderQueue.add(2);
        lock.unlock();

        try {
            Thread.currentThread().sleep(5000);
        } catch (InterruptedException ex) {
            Logger.getLogger(ExplicitLockCondition.class.getName()).log(Level.SEVERE, null, ex);
        }

        lock.lock();
        orderQueue.add(-99);
        lock.unlock();


        for(int i=0; i<ths.length;i++)
        {
            ths[i].interrupt();

        }
        System.out.println("After loop exited!!!");
        for(int i=0; i<ths.length;i++)
        {
        System.out.println("Interrupted thread:" + ths[i].getName() +"with interrupt flag:" + ths[0].isInterrupted());
        }

        for(int i=0; i<ths.length;i++)
        {
            try {
                ths[i].join();
            } catch (InterruptedException ex) {
                Logger.getLogger(ExplicitLockCondition.class.getName()).log(Level.SEVERE, null, ex);
            }
        }

        System.out.println("Program exited!!!");

    }

}

Answer 1

你有

condition.await();

但是发出信号的唯一位置是catch块。

在应用程序的典型运行中，interruptedthread（我们将其称为IT1)将进入while循环和await条件，使其处于等待状态。您的main线程将执行一系列操作，并最终中断IT1。您将注意到条件#await()状态的javadoc

• 在进入此方法时设置了中断状态；或
• 在等待时中断，并且支持中断线程挂起，

然后抛出interruptedexception，并清除当前线程的中断状态。

因此，执行离开while块，转到catch。在此期间，您的线程IT2仍然拥有锁，因为没有unlock对它进行解锁。然后，catch块调用

this.condition.signalAll();

condition.await();