java 多线程之间进行数据交换

Dear 丶 2022-06-01 03:54 215阅读 0赞

import java.util.concurrent.Exchanger;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    /**
     * 多线程之间交换数据使用Exchanger方法来传递想要传递的数据，并且返回时接受其他线程传递的数
     * @author Bowin
     *
     */
    public class ExchangeTest {  
        public static void main(String[] args) {  
            ExecutorService service =Executors.newCachedThreadPool();  
            final Exchanger<Object> exchanger = new Exchanger<>();  
            service.execute(new Runnable() {  
                @Override  
                public void run() {  
                    try{  
                        String data1 = "零食";  
                        System.out.println("线程"+Thread.currentThread().getName()+  
                                "正在把数据 "+data1+" 换出去");  
                        Thread.sleep((long)Math.random()*10000);  
                        String data2 = (String)exchanger.exchange(data1);//等待其他线程执行exchange方法,并获取其他线程的执行结果
                        System.out.println("线程 "+Thread.currentThread().getName()+  
                                "换回的数据为 "+data2);  
                    }catch(Exception e){  
                        e.printStackTrace();  
                    }  
                      
                }  
            });  
              
            service.execute(new Runnable() {  
                  
                @Override  
                public void run() {  
                    try{  
                        String data1 = "钱";  
                        System.out.println("线程"+Thread.currentThread().getName()+  
                                "正在把数据 "+data1+" 交换出去");  
                        Thread.sleep((long)(Math.random()*10000));  
                        String data2 =(String)exchanger.exchange(data1);  
                        System.out.println("线程 "+Thread.currentThread().getName()+  
                                "交换回来的数据是: "+data2);  
                    }catch(Exception e){  
                        e.printStackTrace();  
                    }  
                      
                      
                }  
            });  
        }  
    }