异步执行

Posted 2022-02-16 赵钱富贵

public void execute()
        //来一个线程池
        ExecutorService executor = Executors.newFixedThreadPool(2);
        CompletableFuture<Integer> future1= CompletableFuture.supplyAsync(new Supplier<Integer>()
        
            @Override
            public Integer get() 
                for(int i=0;i<10;i++) 
                    System.out.println("task1:"+i);
                    sleep(1000);
                
                
                return 333;
            
        ,executor);
        
        
        CompletableFuture<Integer> future2 =CompletableFuture.supplyAsync(new Supplier<Integer>()
        
            @Override
            public Integer get() 
                for(int i=0;i<10;i++) 
                    System.out.println("task2:"+i);
                    sleep(1000);
                
                return 666;
            
        ,executor);
        
        //等待所有任务执行结束
        CompletableFuture<Void> all= CompletableFuture.allOf(future1,future2);
        all.thenAccept(e->
            //关闭线程池
            executor.shutdown();
            System.out.println("执行结束");
           
        );


    static void sleep(long millis) 
        try 
            Thread.sleep(millis);
        
        catch (InterruptedException e) 
            // TODO Auto-generated catch block
            e.printStackTrace();