java同步例子之FutureTask

最新推荐文章于 2022-07-22 22:14:51 发布

iteye_1359

最新推荐文章于 2022-07-22 22:14:51 发布

阅读量408

点赞数

分类专栏： java 文章标签： java FutureTask concurrent

本文链接：https://blog.csdn.net/iteye_1359/article/details/82439710

版权

java 专栏收录该内容

23 篇文章

订阅专栏

本文探讨了如何使用Java的FutureTask实现并发计算，并在指定时间内获取计算结果，包括任务执行、等待、超时处理及异常捕获。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

仅在计算完成时才能获取结果；如果计算尚未完成，则阻塞 get 方法。一旦计算完成，就不能再重新开始或取消计算.


package concurrent;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

/**
 * FutureTask
 * 
 * @author user
 * 
 */
public class FutureTaskTest {

	private final FutureTask<ProductInfo> future = new FutureTask<ProductInfo>(
			new Callable<ProductInfo>() {
				public ProductInfo call() throws InterruptedException {
					return loadProductInfo();
				}
			});

	public ProductInfo loadProductInfo() throws InterruptedException {
		System.err.println("=====waiting========");
		Thread.sleep(5000);
		return new ProductInfo();
	}

	private final Thread thread = new Thread(future);

	public void start() {
		thread.start();
	}

	public ProductInfo get() throws InterruptedException, ExecutionException,
			TimeoutException {
		try{
			return future.get(1, TimeUnit.SECONDS);
		} catch(TimeoutException e) {
                        //future.cancel(true); //取消任务
			System.err.println("火速返回，失败！");
			return future.get(10, TimeUnit.SECONDS);
		}
	}

	/**
	 * @param args
	 * @throws ExecutionException
	 * @throws InterruptedException
	 * @throws TimeoutException
	 */
	public static void main(String[] args) throws InterruptedException,
			ExecutionException, TimeoutException {
		FutureTaskTest test = new FutureTaskTest();
		test.start();
		System.err.println("=======begin========");
		System.err.println(test.get());
		System.err.println("=======end========");
	}

}

class ProductInfo {
	public String toString() {
		return "**ProductInfo**";
	}
}