多线程设计模式 -- futrue --新特性

请求数据线程

public class RequestData implements Callable<Data> {

	@Override
	public Data call() {
		// TODO Auto-generated method stub
		int[] arr = new int[100];
		try {
			Thread.sleep(2000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		for (int i = 0; i < 100; i++) {
			arr[i] = i;
		}

		Data data = new Data();
		data.setDataArr(arr);
		return data;

	}

}

数据

public class Data {
	
	private int[] dataArr = new int[100];

	public int[] getDataArr() {
		return dataArr;
	}

	public void setDataArr(int[] dataArr) {
		this.dataArr = dataArr;
	}
}

测试类

public class Main {

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

		ExecutorService es = Executors.newFixedThreadPool(4);

		RequestData r1 = new RequestData();
		RequestData r2 = new RequestData();
		RequestData r3 = new RequestData();
		RequestData r4 = new RequestData();

		System.out.println("Begin......");
		
		Future<Data> f1 = es.submit(r1);
		Future<Data> f2 = es.submit(r2);
		Future<Data> f3 = es.submit(r3);
		Future<Data> f4 = es.submit(r4);
		

		Data data1 = null;
		Data data2 = null;
		Data data3 = null;
		Data data4 = null;
		try {
			data1 = f1.get();
			data2 = f2.get();
			data3 = f3.get();
			data4 = f4.get();
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (ExecutionException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		System.out.println(data1.getDataArr().length);
		System.out.println(data2.getDataArr().length);
		System.out.println(data3.getDataArr().length);
		System.out.println(data4.getDataArr().length);
		
		System.out.println("End......");
		
		

		es.shutdown();

	}

}