多线程-java.util.concurrent.Exchanger

2021-03-01 19:28

阅读：506

标签：class 模式 string try 就是 out interrupt test style

Exchanger的功能可以使2个线程之间传输数据,它比生产者消费者模式使用的wait/notify要更加方便,类Exchanger中的exchange()方法具有阻塞的特色,也就是此方法被调用后等待其他线程来取得数据，如果没有其他线程取得数据，则一直阻塞等待。Exchanger主要有两个方法 :exchanger(V x)、exchanger(V x, long timeout, TimeUnit unit)。下面看看一个很简单的示例:

public class ExchangerTest {
    public static void main(String[] args) {
        Exchanger exchanger = new Exchanger();
        new Thread(new WorkA(exchanger)).start();
        new Thread(new WorkB(exchanger)).start();
    }
}

class WorkA extends Thread{
    private Exchanger exchanger;

    public WorkA(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        try {
            System.out.println("WorkerA想要给WorkerB" + exchanger.exchange("一个比特币"));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

class WorkB extends Thread{
    private Exchanger exchanger;

    public WorkB(Exchanger exchanger) {
        this.exchanger = exchanger;
    }

    @Override
    public void run() {
        try {
            System.out.println("WorkerB想要给WorkerA" + exchanger.exchange("1w美金"));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

两个线程通过exchange交换数据。这个使用比较简单。

参考：

　　【1】《Java并发编程实战》，高洪岩

多线程-java.util.concurrent.Exchanger

标签：class 模式 string try 就是 out interrupt test style

原文地址：https://www.cnblogs.com/happyflyingpig/p/14425618.html

上一篇：两年Java，去字节跳动写Python和Go

下一篇：NumPy 数组索引、维度增加、拼接

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：多线程-java.util.concurrent.Exchanger
文章链接：http://soscw.com/essay/58695.html

亲，登录后才可以留言！

多线程-java.util.concurrent.Exchanger

参考：

评论

热门文章

推荐文章

最新文章

置顶文章