哥妞 海淀山后有哥妞

JAVA获取线程执行结果的几种方式

2021-01-20

JAVA获取线程执行结果的几种方式

1、Callable 线程

2、使用Future,包括 FutureTask、CompletableFuture

3、使用 CompletionService

获取线程执行结果的几种方式

1、Callable 线程

public class FetchAdTask implements Callable<Ad> {

    @Override
    public Ad call() throws Exception {
        System.out.println("fetch task");
        sleep(1000L);
        return null;
    }
}

2、使用Future,包括 FutureTask、CompletableFuture

CompletableFuture.get();

Future 的优点:可以对任务设置时限,如果超时了,可以取消,然后返回一个默认结果,防止 某一个任务出现问题,导致系统出现问题。

f.get(timeLeft, TimeUnit.NANOSECONDS);

或者通过 invokeAll() 返回限定时间范围内的所有任务的结果。

executor.invokeAll(tasks, time, unit);   

CompletableFuture, 使用 supplyAsync 方法提交线程,使用 get 方法获取结果。

CompletableFuture<Integer> task3 = CompletableFuture.supplyAsync(() -> {
        System.out.println("任务3, 线程名字" + Thread.currentThread().getName());
        try {
            sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return 3;
    });

    CompletableFuture.allOf(task1, task2, task3, task4);
    System.out.println("end: " + new Date());
    task1.get();

3、使用 CompletionService

CompletionService.take();

例子

private static final long TIME_BUDGET = 100L;
private static final Ad DEFAULT_AD = new Ad();

private final ExecutorService executor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors() + 1,
        Runtime.getRuntime().availableProcessors() + 1, 0L,
        TimeUnit.MILLISECONDS, new LinkedBlockingQueue(1000));


public static void main(String[] args) {
    try {
        Test616LimitedTimeTask task = new Test616LimitedTimeTask();
        task.test();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

/**
 * 测试超时取消
 *
 * @throws InterruptedException
 */
void test() throws InterruptedException {
    Ad ad = null;
    long endNanos = System.nanoTime() + TIME_BUDGET;
    Future<Ad> f = executor.submit(new FetchAdTask());
    try {
        long timeLeft = endNanos - System.nanoTime();
        // 增加参数 超时时间和超时时间的单位
        ad = f.get(timeLeft, TimeUnit.NANOSECONDS);
    } catch (ExecutionException e) {
        ad = DEFAULT_AD;
    } catch (TimeoutException e) {
        // 超时,取消任务
        ad = DEFAULT_AD;
        System.out.println("超时取消");
        f.cancel(true);
    }
}    

优点:多个 CompletionService 可以共享一个 Executor,因此可以创建一个对于特定计算私有, 又能共享一个公共 Executor 的 ExecutorCompletionService。

4、使用 CountDownLatch 的 await() 方法

public static void main(String[] args) throws InterruptedException {
   //倒计时计数器,
   CountDownLatch latch = new CountDownLatch(10);
   for (int i = 0; i < 10; i++) {
       new Thread(() -> {
           for (int j = 0; j < 100000; j++) {
               num.getAndIncrement();
           }
           //计数器减1
           latch.countDown();
       }).start();
   }
   //打开开关
   latch.await();
   System.out.println(num.get());
}

源码:https://github.com/zhongsb/Java-learning.git


1分也是爱


微信扫描二维码,关注公众号 (转载本站文章请注明作者和出处 哥妞-geniu)

Similar Posts

评论