java再复习-Exchanger的使用

    xiaoxiao2021-03-25  38

    Exchanger:使用两个线程间交换数据,阻塞的等待。

    例子:

    public class ExchangerDemo2 { public static void main(String[] args) throws Exception { final Exchanger<String> exchanger = new Exchanger<>(); new Thread(){ public void run() { try { sleep(2000); //会一直阻塞,知道有其他线程调用了exchange方法,并且可以得到对方传过来的数据。 String data = exchanger.exchange(getName() + "的毒品.."); System.out.println("thread得到:"+data); } catch (InterruptedException e) { e.printStackTrace(); } }; }.start(); //会一直阻塞,知道有其他线程调用了exchange方法,并且可以得到对方传过来的数据。 String data = exchanger.exchange(Thread.currentThread().getName() + "的1000块钱..."); System.out.println("main得到:" +data); System.out.println("over.."); } } 这两个方法会一直相互阻塞,值得注意的是:exchange方法有一个超时的重载,而且像countDownLatch的await方法,也有超时重载的。

    exchanger.exchange(x, timeout, unit)

    转载请注明原文地址: https://ju.6miu.com/read-27387.html

    最新回复(0)