我要说的是,我可以执行。

如果你想永远走下去,我会永远走下去。

共同的替代办法是使用

while(!Thread.currentThread().isInterrupted()) {

或

while(!Thread.interrupted()) {

因此,你可能希望做这样的事情。

while(beingServed)
{
    //check if the customer is done being served (set beingServed to false)
}

这样一来,如果你想要死亡,就会越狱。

为什么不使用代表消费者存在的<条码>boolean?

public class Consumer extends Thread {
    private volatile boolean present;

    public Consumer() {
        present = true;
    }

    public void run() {
        while (present) {
            // Do Stuff
        }
    }

    public void consumerLeft() {
        present = false;
    }
}

First, you can create for each consumer and after the consumer will finish it s job than the consumer will finish the run function and will die, so no need for infinite loop. however, creating thread for each consumer is not good idea since creation of thread is quite expensive in performance point of view. threads are very expensive resources. In addition, i agree with the answers above that it is better to implement runnable and not to extends thread. extend thread only when you wish to customize your thread. I strongly suggest you will use thread pool and the consumer will be the runnable object that ran by the thread in the thread pool. the code should look like this:

public class ConsumerMgr{

 int poolSize = 2;

int maxPoolSize = 2;

long keepAliveTime = 10;

ThreadPoolExecutor threadPool = null;

final ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(
        5);

public ConsumerMgr()
{
    threadPool = new ThreadPoolExecutor(poolSize, maxPoolSize,
            keepAliveTime, TimeUnit.SECONDS, queue);

}

public void runTask(Runnable task)
{
    // System.out.println("Task count.."+threadPool.getTaskCount() );
    // System.out.println("Queue Size before assigning the
    // task.."+queue.size() );
    threadPool.execute(task);
    // System.out.println("Queue Size after assigning the
    // task.."+queue.size() );
    // System.out.println("Pool Size after assigning the
    // task.."+threadPool.getActiveCount() );
    // System.out.println("Task count.."+threadPool.getTaskCount() );
    System.out.println("Task count.." + queue.size());

}

http://em>extend不是一个好的想法。 read(除非你正在穿上一种新型的read子——永远不会穿透)。

最好的办法是将Runnable传送给Thread s Constructionor。

public class Consumer implements Runnable {

    public void run() {
        while (true) {
            // Do something
        }
    }
}

new Thread(new Consumer()).start();

一般而言,while(true) 是科索沃,但你必须处理由于正常wake或伪造的催交而中断的问题。 该网站有许多例子。

页: 1 Java Concurrency in Practice。

对于生产者消费模式,你最好使用等待()和通知()。 见tutorial 。 这比在(真实)休息期间更有成效。