zoukankan      html  css  js  c++  java
  • Java8-Executors-No.02

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    public class Executors2 {
    
        public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
    //        test1();
    //        test2();
            test3();
        }
    
        private static void test3() throws InterruptedException, ExecutionException, TimeoutException {
            ExecutorService executor = Executors.newFixedThreadPool(1);
    
            Future<Integer> future = executor.submit(() -> {
                try {
                    TimeUnit.SECONDS.sleep(2);
                    return 123;
                }
                catch (InterruptedException e) {
                    throw new IllegalStateException("task interrupted", e);
                }
            });
    
            future.get(1, TimeUnit.SECONDS);
        }
    
        private static void test2() throws InterruptedException, ExecutionException {
            ExecutorService executor = Executors.newFixedThreadPool(1);
    
            Future<Integer> future = executor.submit(() -> {
                try {
                    TimeUnit.SECONDS.sleep(1);
                    return 123;
                }
                catch (InterruptedException e) {
                    throw new IllegalStateException("task interrupted", e);
                }
            });
    
            executor.shutdownNow();
            future.get();
        }
    
        private static void test1() throws InterruptedException, ExecutionException {
            ExecutorService executor = Executors.newFixedThreadPool(1);
    
            Future<Integer> future = executor.submit(() -> {
                try {
                    TimeUnit.SECONDS.sleep(1);
                    return 123;
                }
                catch (InterruptedException e) {
                    throw new IllegalStateException("task interrupted", e);
                }
            });
    
            System.out.println("future done: " + future.isDone());
    
            Integer result = future.get();
    
            System.out.println("future done: " + future.isDone());
            System.out.print("result: " + result);
    
            executor.shutdownNow();
        }
    
    }
    
  • 相关阅读:
    解决问题:Jenkins Web 部署任务失败
    微信开发者调试工具官方下载地址
    Android机USB调试功能
    DOMContentLoaded 和 Load 和 Finish
    Json to string, string to Json
    static 和 new对象的区别
    c# Image/Pdf 预览
    在console 中执行异步方法
    c# 压缩zip
    js -- string 转 html
  • 原文地址:https://www.cnblogs.com/bilaisheng/p/10210906.html
Copyright © 2011-2022 走看看