`
wanxiaotao12
  • 浏览: 455981 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Future

 
阅读更多

如果想获取某一线程执行后的结果, 则使用Callable(类似于Runnable), Future(表示一个任务的生命周期, 并提供了相应的方法判断是否已经完成或取消, 以及任务的执行结果)

 

package com.test;

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;

public class Test4 {

	public static void main(String[] args) throws InterruptedException, ExecutionException {
		ExecutorService es = Executors.newCachedThreadPool();// 创建线程池对象
		
		List<Future<String>> result = new ArrayList<Future<String>>();// 放结果用的集合

		for (int i = 0; i < 3; i++) {

			Future<String> f = es.submit(new MyCall(i));// 线程执行完成以后可以通过引用获取返回值

			result.add(f);

		}

		for (Future<String> f : result) {

			System.err.println("返回值:" + f.get());// get方法等线程返回结果, 

		}

		System.err.println("完成....");

	}

}


//声明一个类,可以被调用,类似于线程,但它可以拥有返回值

class MyCall implements Callable<String> {

	private int seq;

	public MyCall(int seq) {

		this.seq = seq;

	}

	// 抛出异常并可以拥有返回值

	public String call() throws Exception {

		System.err.println("执行" + seq + ","
				+ Thread.currentThread().getName());

		Thread.sleep(3000);

		System.err.println("Weak up " + seq);

		return "完成" + seq;// 这是返回值

	}

}

 

 

参考:http://westyi.iteye.com/blog/714935

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics