How to use BlockingQueue blocking queue to realize Mutual exclusive synchronous Communication in java

This article introduces how to use BlockingQueue blocking queue in java to achieve mutually exclusive synchronous communication. The content is very detailed. Interested friends can use it for reference. I hope it will be helpful to you.

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 takeblockingQueue = new ArrayBlockingQueue (1); BlockingQueue putblockingQueue = new ArrayBlockingQueue (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 () } on how to use BlockingQueue blocking queue in java to achieve mutually exclusive synchronous communication is shared here. I hope the above content can be helpful to you and learn more knowledge. If you think the article is good, you can share it for more people to see.