package luo.common.thread.pool;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class App {

	public static void main(String[] args) throws InterruptedException, ExecutionException {
		
		List<String> lists = new ArrayList<String>();
		for (int i = 0; i < 100000; i++) {
			lists.add("shuju"+i);
		}
		
		List<SessionCallable<String>> callables= SyncThreadPool.getSessionCallable(lists);
		List<Future<String>> syncFnData = SyncThreadPool.syncFn(callables);
		//´¦Àí½á¹û
		List<String> results = new ArrayList<String>();
		for (Future<String> future : syncFnData) {
			if(future.isDone()){
				results.add(future.get()) ;
			}
		}
		//System.err.println(results);
	}
}