callable和Future

      Callable，线程执行任务，它是jdk1.5加入到api中的，相比于Runnable，它有俩大优点：第一，它可以有返回值，且返回值由我们事先泛型的Callable<T>中的T决定。第二，当我们在执行一个任务时，如果超时，我们可以取消它的执行。
      下面的话，就看个例子咯。

/**
 *
 * @author li jian
 * @mail [e-mail]
 * @date 2012-9-25 上午09:47:37
 */
public class Client {

	public static void main(String[] args) throws InterruptedException,              ExecutionException, TimeoutException {

		ExecutorService exec = Executors.newSingleThreadExecutor();

       /**
		 * 执行Callable有俩中方法，
		 *          1. 就是下文的代码段，把Callable传给FutureTask，
		 *             创建FutureTask，然后execute FutureTask
		 *          2.Future<Boolean>  futer = exec.submit
		 *                           (new GirlAnswerCallable())
		 *            submit一个Callable，然后返回一个Future
		 *
		 *
		 */
      FutureTask<Boolean> futer = new FutureTask<Boolean>
                                   (new GirlAnswerCallable());

		exec.execute(futer);


		System.out.println("To girl: When I first saw you, I fell in love with you.");

		boolean success = false;

		try {

			/**
			 * 这里假设：
			 *         男孩向女孩表白，如果女孩超过一定时间没回复的话，
			 *         那就果断cancel吧，都放开点。
			 *         如果，在限定的时间回复的话，当然，女方回复必须是
			 *         false或者true，当然，听到这话，你应该知道什么意
			 *         思了吧.
			 *
			 *
			 *
			 *
			 */

			//如果延迟的话，便会抛出TimeoutException异常
			success = futer.get(5, TimeUnit.SECONDS);

			System.out.print("girl says: ");
			System.out.println(success ? "yes." : "no.");

		}catch(TimeoutException e) {

			System.out.println("女孩超过5秒没回复，你就死了这份心吧。");

			/**
			 * 中断运行，不能让女方给张"好人卡"，拔腿就跑.
			 * 其实，这里是变相的要女方不要说话了（不执行），
			 * 因为男方走了，女方说话给谁听。
			 * 
			 * 当然如果是futer.cancel(false)，就是说明，
			 * 想听她继续说，想"死"的明白
			 *
			 */
			futer.cancel(true);

		}

		exec.shutdown();

	}

}

 

/**
 * 女孩子的回复
 * @author li jian
 * @mail [e-mail]
 * @date 2012-9-25 上午09:36:20
 */
public class GirlAnswerCallable  implements Callable<Boolean>{

	private static  final Random random  = new Random();

	@Override
	public Boolean call() throws Exception {

		TimeUnit.SECONDS.sleep(ansewerTime());

		return yesOrNo();
	}


	private int ansewerTime() {

		return random.nextInt(20);

	}

	private boolean yesOrNo() {

		return random.nextBoolean();
	}

}