`
sdu_wizard
  • 浏览: 98742 次
  • 性别: Icon_minigender_1
  • 来自: 亚特兰蒂斯
社区版块
存档分类
最新评论

可以返回执行结果的线程

阅读更多

java中继承自Thread或者实现Runnable接口的类都是可用于执行多线程任务的类

要想得到任务执行的结果,可以向类的构造方法中传入类类型参数,例如

 

class AddThread implements Runnable{
	
	private int a;//操作数a
	private int b;//操作数b
	public Object result;//结果
	
	/**
	 * 构造方法
	 * @param a
	 * @param b
	 */
	public AddThread(int a,int b) {
		super();
		this.a = a;
		this.b = b;
	}

	@Override
	public void run()  {
		result=a+b;
	}
	
}
 

用这种方式可以获得线程执行的结果,但是不知道线程何时执行完,也就是不知道何时去取执行结果

用下面这种方式,可以解决这个问题

 

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * 加法线程类,做两个数的相加操作,返回结果
 * @author admin
 *
 */
class AddThread implements Callable<Object>{
	
	private int id;//id字段,相当于线程名称
	private int a;//操作数a
	private int b;//操作数b
	
	/**
	 * 构造方法
	 * @param a
	 * @param b
	 */
	public AddThread(int id,int a,int b) {
		super();
		this.id=id;
		this.a = a;
		this.b = b;
	}

	@Override
	public Object call() throws Exception {
		return a+b;
	}
}

public class Test {

	public static void main(String[] args) throws InterruptedException, ExecutionException {
		ExecutorService exec = Executors.newCachedThreadPool();  
		//Future相当于是用来存放Executor执行的结果的一种容器  
        List<Future<Object>> results = new ArrayList<Future<Object>>();    
        for (int i=0;i<5;i++) {  
            results.add(exec.submit(new AddThread(i,i,i)));  
        }  
        for (Future<Object> fs:results) {
        	//fs.get()会等待线程返回出结果再执行
        	Object count=fs.get();
        	System.out.println(count);
        }  
        exec.shutdown();  
	}
	
}
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics