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();
        }
    
    }
    
  • 相关阅读:
    try catch使用示例
    doxgen生成chm文档和乱码解决方法
    MFC中MessageBox()用法
    UML聚合与组合
    C#网络编程
    单元测试(NUnit)
    Autohotkey
    .NET中的并行
    System.Environment类的使用
    一键VHD
  • 原文地址:https://www.cnblogs.com/bilaisheng/p/10210906.html
Copyright © 2011-2022 走看看