Future接口例子程序

package preschedule;


import java.util.concurrent.*;


public class TaskTest {


	public static void addToPreScheduleTaskQueue(ExecutorService exec) {


		TaskPreScheduler mapTaskPreScheduler =  new TaskPreScheduler();
		Future<Boolean> future = exec.submit(mapTaskPreScheduler);
		Boolean taskResult = null;


		try {
			taskResult = future.get(100, TimeUnit.MICROSECONDS);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (ExecutionException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (TimeoutException e) {
			// TODO Auto-generated catch block
			future.cancel(true); //
			System.out.println(" preSchedule:  interrupted! Over Time Limit! ");
		} finally {
			exec.shutdownNow();
		}


		// 这里判断是否预调度成功，并作相应处理
		if (taskResult == true) // 未超时,TP成功完成
		{
			System.out.println(Thread.currentThread().getName() + " preSchedule Succeeded! ");
		} else
			System.out.println(" preSchedule Failed! ");
	}
 
	
	public static void main(String argv[]) throws Exception {
		ExecutorService exec = Executors.newCachedThreadPool();
		addToPreScheduleTaskQueue(exec);
	}
}


class TaskPreScheduler implements Callable<Boolean> {


	public TaskPreScheduler()
	{
//	   System.out.println(Thread.currentThread().getName()   + " TaskPreScheduler created! ");	
	}
	
	@Override
	public Boolean call() throws Exception {
		// TODO Auto-generated method stub
		System.out.println( Thread.currentThread().getName() +" preschedule called!");
		return true;
	}
}