0

我对 Java 有疑问。我想编写一个程序，其中有一个类 Main，它有一些类（类任务）的线程数组列表，它只写一个字母和数字。Object Main 只是从 ArrayList 中唤醒一个线程，并让它在同一个对象（Main）休眠另一个线程时做某事。但是我在类任务中得到了非法状态的错误：

while(suspended){
wait();
    System.out.println(character);
        }

整个代码

import java.util.ArrayList;


public class Main extends Thread {
ArrayList<Thread> threads;
public Main() {
    super();
    threads = new ArrayList<Thread>();
}

public void run(){
    for(int i = 0; i < 1; i++){
        threads.add(new Thread(new Task(i+65)));
    }
    long cT = System.currentTimeMillis();
    for(int i = 0; i < threads.size(); i++){
        threads.get(i).start();
    }
    while(System.currentTimeMillis() - cT < 10000){
        for(int i = 0; i < threads.size(); i++){
            threads.get(i).start();
            try {
                Thread.sleep(1000);
            } catch (Exception e) {e.printStackTrace();
            }
            threads.get(i).stop();;
        }
    } 


}




public static void main(String[] args) {
//  new Main().start();
    new Thread(new Task(65)).start();

}

}


public class Task implements Runnable {
int nr;
char character;
boolean suspended, resumed, stopped;
public Task(int literaASCII) {
    this.nr = 0;
    character = (char) (literaASCII);
    suspended = true;
    resumed = true;
    stopped = false;
}

@Override
public void run() {
    while(true){
        try{
        while(suspended){
            wait();
            System.out.println(character);
        }
        if(resumed){
            System.out.println("(Wznawiam watek litera: "+character+")");
            resumed = false;
        } 
        System.out.print(nr+""+character+", ");
        nr++;
        int r =  (int)((Math.random()*500) + 500);
        Thread.sleep(r);
        }catch(Exception e){e.printStackTrace();} 
    }
}

synchronized    public void suspend(){
    suspended = true;
    resumed = false; //chyba zbedne
}

synchronized    public void resume(){
    suspended  = false;
    resumed = true;
}


public static void main(String[] args) {
    // TODO Auto-generated method stub

}


}
4

2 回答 2

2

如果您阅读 Javadoc，Thread.start()您会发现它说：

多次启动一个线程是不合法的。特别是，线程一旦完成执行就可能不会重新启动。

这就是你非法状态的来源。

此外，您调用了 Object.wait() 但从未调用过 notify()，这让我相信您对自己在做什么一无所知。所以我建议你拿起一本书，阅读一下 Java 中的多线程和同步。这是一个很难的话题，但是一旦你掌握了它，它就会非常有益。

于 2012-05-11T23:52:39.257 回答
0

someObject.wait()只能由在 上同步的线程调用someObject。JavaDocwait提到了这一点：

当前线程必须拥有该对象的监视器。（来源）

换句话说，这被打破了：

someObject.wait();
wait();

虽然这是有效的：

synchronized(someObject) {
    someObject.wait();
}
synchronized(this) {
    wait();
}

notify但是你从不打电话或notifyAll可疑的事实。

听起来您要实现的是一个阻塞队列：一个线程将项目放入该线程，另一个线程将它们从其中取出并处理它们。如果是这种情况，您应该查看BlockingQueue。

于 2012-05-11T23:57:14.830 回答