invokeAny()与全部异常

 1 package Seven_invokeAny_All_Demo1;
 2 
 3 import java.util.concurrent.Callable;
 4 
 5 public class MyCallableA implements Callable<String> {
 6 
 7     @Override
 8     public String call() throws Exception {
 9         System.out.println("MyCallableA" + Thread.currentThread().getName() + " begin " + System.currentTimeMillis());
10 
11         for (int i = 0; i < 123; i++) {
12             String newString = new String();
13             Math.random();
14             Math.random();
15             Math.random();
16             System.out.println("MyCallableA 在运行中= " + (i + 1));
17         }
18 
19         System.out.println("MyCallableA  " + Thread.currentThread().getName() + " end " + System.currentTimeMillis());
20 
21         if (1 == 1) {
22             System.out.println("1==1");
23             throw new Exception("线程A 报错了AAAAA");
24         }
25 
26         return "return---A";
27     }
28 
29 }

 1 package Seven_invokeAny_All_Demo1;
 2 
 3 import java.util.concurrent.Callable;
 4 
 5 public class MyCallableB implements Callable<String> {
 6 
 7     @Override
 8     public String call() throws Exception {
 9         System.out.println("MyCallableB" + Thread.currentThread().getName() + " begin " + System.currentTimeMillis());
10         for (int i = 0; i < 223; i++) {
11             String newString = new String();
12             Math.random();
13             Math.random();
14             Math.random();
15             System.out.println("MyCallableB 在运行中= " + (i + 1));
16         }
17 
18         System.out.println("MyCallableB  " + Thread.currentThread().getName() + " end " + System.currentTimeMillis());
19 
20         if (1 == 1) {
21             System.out.println("1==1");
22             throw new Exception("线程B 报错了BBBBB");
23         }
24 
25         return "return---B";
26     }
27 
28 }

 1 package Seven_invokeAny_All_Demo1;
 2 
 3 import java.util.ArrayList;
 4 import java.util.List;
 5 import java.util.concurrent.ExecutionException;
 6 import java.util.concurrent.ExecutorService;
 7 import java.util.concurrent.Executors;
 8 
 9 public class Run {
10 
11     public static void main(String[] args) {
12         try {
13 
14             List list = new ArrayList();
15 
16             list.add(new MyCallableB());
17             list.add(new MyCallableA());
18 
19             ExecutorService service = Executors.newCachedThreadPool();
20 
21             String getString = (String) service.invokeAny(list);;
22 
23             System.out.println("main取得返回值=" + getString);
24             
25             System.out.println("main---end");
26         } catch (InterruptedException e) {
27             System.out.println("进入   catch InterruptedException");
28             e.printStackTrace();
29         } catch (ExecutionException e) {
30             System.out.println("进入   ExecutionException");
31             e.printStackTrace();
32         }
33 
34     }
35 
36 }

 1 package Seven_invokeAny_All_Demo1;
 2 
 3 import java.util.concurrent.Callable;
 4 
 5 public class MyCallableA implements Callable<String> {
 6 
 7     @Override
 8     public String call() throws Exception {
 9         
10         try{
11         System.out.println("MyCallableA" + Thread.currentThread().getName() + " begin " + System.currentTimeMillis());
12 
13         for (int i = 0; i < 123; i++) {
14             String newString = new String();
15             Math.random();
16             Math.random();
17             Math.random();
18             System.out.println("MyCallableA 在运行中= " + (i + 1));
19         }
20 
21         System.out.println("MyCallableA  " + Thread.currentThread().getName() + " end " + System.currentTimeMillis());
22 
23         if (1 == 1) {
24             System.out.println("1==1");
25             throw new Exception("线程A 报错了AAAAA");
26         }
27         }catch(Exception e){
28             System.out.println(e.getMessage() +"  :左边的信息就是捕获到的信息!!!");
29         }
30 
31         return "return---A";
32     }
33 
34 }

package Seven_invokeAny_All_Demo1;

import java.util.concurrent.Callable;

public class MyCallableA implements Callable<String> {

    @Override
    public String call() throws Exception {
        
        try{
        System.out.println("MyCallableA" + Thread.currentThread().getName() + " begin " + System.currentTimeMillis());

        for (int i = 0; i < 123; i++) {
            String newString = new String();
            Math.random();
            Math.random();
            Math.random();
            System.out.println("MyCallableA 在运行中= " + (i + 1));
        }

        System.out.println("MyCallableA  " + Thread.currentThread().getName() + " end " + System.currentTimeMillis());

        if (1 == 1) {
            System.out.println("1==1");
            throw new Exception("线程A 报错了AAAAA");
        }
        }catch(Exception e){
            System.out.println(e.getMessage() +"  :左边的信息就是捕获到的信息!!!");
            throw e;//重新抛出异常
        }

        return "return---A";
    }

}