Java多线程-新特性-有返回值的线程-学习笔记2

在Java5之前，线程是没有返回值的，常常为了“有”返回值，破费周折，而且代码很不好写。或者干脆绕过这道坎，走别的路了。

现在Java终于有可返回值的任务（也可以叫做线程）了。

可返回值的任务必须实现Callable接口，类似的，无返回值的任务必须Runnable接口。

执行Callable任务后，可以获取一个Future的对象，在该对象上调用get就可以获取到Callable任务返回的Object了。

下面是个很简单的例子：

 

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

//有返回值的多线程  需事先callable接口
public class CallableFutureTest {

	public static void main(String[] args) throws Exception {
		CallableFutureTest ct = new CallableFutureTest();

		// 创建一个线程池
		ExecutorService pl = Executors.newFixedThreadPool(2);

		// 创建两个有返回值的线程对象
		Callable c1 = ct.new MyCallable("1");
		Callable c2 = ct.new MyCallable("2");
		Callable c3 = ct.new MyCallable("3");
		Callable c4 = ct.new MyCallable("4");

		Future f1 = pl.submit(c1);
		Future f2 = pl.submit(c2);
		Future f3 = pl.submit(c3);
		Future f4 = pl.submit(c4);

		// 从Future中获取任务的ID号
		System.out.println("======" + f1.get());
		System.out.println("======" + f2.get());
		System.out.println("======" + f3.get());
		System.out.println("======" + f4.get());

		System.out.println("主线程结束…………………………………………");
	}

	class MyCallable implements Callable {

		private String id;

		public MyCallable(String id) {
			this.id = id;
		}

		@Override
		public Object call() throws Exception {
			System.out.println(Thread.currentThread().getName() + " : " + id);
			Thread.sleep(1000);
			return "Thread返回值id :" + id;
		}

	}
}