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源点
注意:本文归作者所有,未经作者允许,不得转载