6

我正在尝试编写生产者消费者模型（Java 中的生产者线程和消费者线程）

我想知道如何处理方法和类的方法InterruptedException抛出的问题Thread.sleepObjectwait()

package producerconsumer;

import java.util.ArrayList;

public class Consumer implements Runnable {

    ArrayList<Integer> container;

    @Override
    public void run() {
        while(true){
        System.out.println("Consumer Thread Running");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        if(null==container){
            System.out.println("container is null");
        }
        //Removing values from Arraylist
        synchronized (container) {
            if(container.size()==0){
                try {
                    container.wait();
                } catch (InterruptedException e) {
                    //How to tackle this exception
                    e.printStackTrace();
                }
            }
            Integer removedInteger = container.remove(container.size()-1);
            System.out.println("removedInteger..."+removedInteger);
        }
        }
    }

    public void setContainer(ArrayList<Integer> container) {
        this.container = container;
    }
}

这是我举的一个例子，在这个例子中，可能不需要处理这些异常（我的假设）。

但我想知道我们需要处理这个异常的不同场景可能是什么。

4

1 回答 1

11

我想知道如何处理 Thread.sleep 方法和 Object Class 的 wait 方法抛出的中断异常

有两件重要的事情需要意识到InterruptedException。首先，当它被抛出时，中断标志Thread被清除。因此，您应该始终执行以下操作：

} catch (InterruptedException e) {
    // re-add back in the interrupt bit
    Thread.currentThread().interrupt();
    ...
}

这是一个非常重要的模式，因为它允许其他可能调用你的代码来检测中断。

其次，就线程而言，如果它们被中断，它们很可能应该清理并退出。这当然取决于你，程序员，但一般行为是终止并退出正在执行的操作——通常是因为程序试图关闭。

} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    // we are being interrupted so we should stop running
    return;
}

最后，对于任何异常处理，默认的 Eclipse 模板通常都是错误的。绝不是e.printStackTrace();例外。弄清楚你想用它做什么：将它作为另一个异常重新抛出，将它记录在更好的地方，或者退出线程/方法/应用程序。

于 2012-04-25T13:49:52.257 回答