中循环查询运算的状态，如果运算没有完成，则主线程sleep100毫秒，然后继续查询，这种方式虽然可行，但由于主线程循环查询，消耗了大量的CPU时间，因此效率很低。
从java线程中获得运算结果(3)
时间:2010-12-08
3。wait/notify方式（较好）
第三种方法使用wait/notify的形式，当运算没有结束的时候，主线程进入睡眠状态，这时它不占用CPU，因此效率较高。
public class AddThread
extends Thread {
//在这个object上wait
private Object lock;
private int result = 0;
private boolean hasDone = false;
public AddThread(Object lock) {
this.lock = lock;
}
public void run() {
for (int i = 0; i <= 10000; i++)
result += i;
//运算结束，通知等待的线程
synchronized(lock) {
hasDone = true;
lock.notifyAll();
}
}
public boolean hasDone() {
return hasDone;
}
public int getResult() {
return result;
}
}
//主线程
public class Test {
public static void main(String[] args) {
Object lock = new Object();
AddThread thread = new AddThread(lock);
thread.start();
synchronized(lock) {
while (!thread.hasDone()) {
try {
//当运算没有结束，主线程进入睡眠状态，当addThread执行notifyAll时，会唤醒主线程
lock.wait();
}
catch (InterruptedException ex) {
}
}
}
if (thread.hasDone())
System.out.println("result is " + thread.getResult());
}
}
从java线程中获得运算结果(4)
时间:2010-12-08
4。使用callback（较好）
我觉得这是最好的一种方式，当运算完成后，AddThread自动调用结果处理类。将其扩展可以成为使多个listener对结果进行处理，这里用到了Observer模式，这种方法很简单，不需要考虑同步机制，具体实现如下：
//对结果进行处理的接口
public interface ResultProcessor {
public void process(int result);
}
public class AddThread extends Thread {
private ResultProcessor processor;
public AddThread(ResultProcessor processor) {
this.processor = processor;
}
public void run() {
int result = 0;
for(int i = 0; i <= 10000; i++) {
result += i;
}
//对结果进行处理
processor.process(result);
}
}
public class Test implements ResultProcessor {
public void process(int result) {
System.out.println("result is " + result);
}
public static void main(String[] args) {
Test test = new Test();
AddThread thread = new AddThread(test);
thread.start();
}
}
结果显示： result is 50005000
代码如上面，AddThread的构造函数传进一个结果处理类,当运算完成时，自动调用这个类的处理函数对结果进行处理。比较起来，我觉得这种方法最好。 |
