java多執行緒使用BlockingQueue阻塞佇列實現互斥同步通訊
阿新 • • 發佈：2019-09-13
package com.study;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class BlockingQueueDemo {
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
final BlockingQueueClass blockingQueueClass = blockingQueueDemo.new BlockingQueueClass();
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
blockingQueueClass.put();
}
}
});
thread.start();
Thread thread2 = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
blockingQueueClass.take();
}
}
});
thread2.start();
}
class BlockingQueueClass{
BlockingQueue<Integer> takeblockingQueue = new ArrayBlockingQueue<Integer>(1);
BlockingQueue<Integer> putblockingQueue = new ArrayBlockingQueue<Integer>(1);
{
try {
takeblockingQueue.put(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void put(){
try {
putblockingQueue.put(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("put...");
try {
takeblockingQueue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void take(){
try {
takeblockingQueue.put(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("take...");
try {
putblockingQueue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}