TransferQueue实现线程通信

star2017 1年前 ⋅ 1658 阅读

LinkedTransferQueue是一个长度为0的线程队列,它的原理是一个线程把东西放进去,同时该线程不松手(进入阻塞),然后另一个线程去拿的时候,第一个线程才恢复,然后第二个线程再放进去,第一个线程就去拿。。如此往复

示例代码:

package com.debuggg.test1.main3;

import java.util.concurrent.LinkedTransferQueue;
import java.util.concurrent.TransferQueue;

public class TransferQueueTest {
    public static void main(String[] args) {
        char[] c1 = "12345678".toCharArray();
        char[] c2 = "ABCDEFGH".toCharArray();
        TransferQueue<Character> queue = new LinkedTransferQueue<>();

        new Thread(() -> {
            for (char c : c1) {
                try {
                    queue.transfer(c);
                    System.out.print(queue.take());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"t1").start();

        new Thread(() -> {
            for (char c : c2) {
                try {
                    System.out.print(queue.take());
                    queue.transfer(c);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"t1").start();
    }
}
更多内容请访问:IT源点

相关文章推荐

全部评论: 0

    我有话说: