转载

在Java中本地进行线程间数据传输的三种方式和源码展示

在线程之间进行通信或发信号时首先想到的是java.lang.Object类方法：wait，notify和notifyAll。这是最基本和最广泛认可的概念，但本博客并非讲这些。

JVM实例上运行的线程缺少强大的预设模型，就像在UNIX中进行交互通信一样，尽管有一些第三方框架可以帮助我们实现这一意图并在角落案例中运行良好，本博客特别针对使用Java中的三个本地概念进行线程间通信： Cyclic Barrier循环屏障，Count Down Latch倒计时锁存和Pipes管道。

1.Cyclic Barrier

扩展java.util.concurrent.CyclicBarrier类以进行线程间数据传输。它基本上是一种同步技术，它允许每个线程的程序计数器在各个线程中的公共屏障点上停止，此时，可以使用共享状态传输数据，然后线程可以相应地继续。

演示的示例代码将使用生产者 - 消费者模型。父线程激活class.Producer和class.Consumer线程启动。当生产者从文件中读取数据时，消费者首先到达公共屏障并停止。生产者线程将结果存储在父线程的阻塞队列中。一旦生产者到达屏障点，此时生产者和消费者都会释放屏障，消费者从队列中检索数据并继续。

这个模型的一个好的用例是线程的输入依赖于另一个线程的输出。在这种情况下，消费者线程可以执行所有必要的启动并在屏障处等待接收输入数据。按照此github链接进行循环屏障的完整实施。

逻辑模板：
<b>class</b>.Producer thread 
step1：start 
step2：进行必要的计算和逻辑
step3：将要传输的所有数据写入阻塞队列
step4：达到循环屏障点，如果所有的线程都到达屏障点 - >继续
步骤5：进行清理和/或结束

<b>class</b>.Consumer thread 
step1：start 
step2：启动任何与生产者无关的数据逻辑处理
step3 到达循环屏障点，如果所有线程到达障碍 - >继续
step4：从队列中删除数据
step5：处理数据，清理并结束

2.Count Down Latch

这是一种在等待和到达模型中使用的同步技术，但它在这里以生产者 - 消费者方式实现。

生产者线程到达某一点，打上一个标志并立即继续前进，而不像循环屏障那样的生产者线程会暂停在这里，消费者线程在某个点停止开始程序计数器计数，一直等待生产者线程打上一个标志以后才继续运行。

这个模型可以被修改后可用于线程间通信。生产者线程在到达该点之前将一些数据推送到阻塞队列然后引发一个标志，等待的消费者跟踪所有这些标志并等待获得所需的标志号码，然后它开始从阻塞队列中提取数据。

演示的示例代码将具有两个生成器线程，一个消费者者线程和一个大小为2的有界阻塞队列。生产者线程每个读取不同的输入文件，然后将其传输到生产者线程，生产者线程将其打印到屏幕上。好用例是当服务器中的数据库对象仅批量写入时，它充当使用者并等待预设号码。许多生产者线程将其数据推入队列，引发标志并继续而不等待。按照这个github链接进行倒计时锁存器的完整实现。

逻辑模板：
<b>class</b>.Producer1和<b>class</b>.Producer2
step1：启动 
step2：做必要的计算和逻辑
step3：写入要传输的所有数据到阻塞队列
step4：打上标志并继续而不等待
step5：做一些逻辑并结束

<b>class</b>.Consumer 
step1：启动
step2：做一些逻辑并等待一个点接收数据
step3：跟踪标志/锁存器，如果数量到达 - >继续
step4：从队列中拉出数据step5 
：使用数据并结束

3.来自java.io的Pipes

class.PipedReader 和class.PipedWriter 允许在定义的点与其他线程直接通信。生产者和消费者必须共同访问某一点，生产开始以块的形式推送数据，正在等待管道打开的消费者者开始提取数据。

理解和实施这个概念相对简单。pipe在现场环境中表现不佳，因此在开发人员社区中已被弃用。另一个主要缺点是它仅支持一对一转移。只能有一个生产者和一个消费者。一个很好的用例是当它用于在一次性任务中引导数据时，它与较新的java.nio包一起使用。关注pipeReader和pipeWriter完整实现的github链接。

逻辑模板
<b>class</b>.Producer thread 
step1：启动
step2：做一些逻辑并到达执行管道的循环
step3：将数据推入流中并在完成后继续
step4：做一些逻辑并结束

<b>class</b>.Consumer thread 
step1：启动
step2：做一些逻辑并到达管道读取器点
step3：一旦管道有值拉数据并存储它
step5：完全读取所有数据，做一些逻辑并结束

异构线程之间的线程间通信的三种方式只是作者在完成工作时修改/扩展本机概念的努力。如在用例场景中所理解的，倒计时锁存器具有更广泛的可用性范围并且可以被广泛采用。

一个主要提示是异常，提供障碍或锁存器具有底层异常，异常处理程序也有机会重试数据传输。这些概念的实现很广泛，本博客试图将生产者 - 消费者的注释和 github 示例放入其中。

原文 https://www.jdon.com/51801

正文到此结束