[Function add]

1.Add test for array blocking queue.

Author: Seanforfun

Algorithm(4th_Edition)/src/ca/mcmaster/queue/arrayblockingqueue/ArrayBlockingQueueConsumer.java

@@ -11,10 +11,9 @@ public ArrayBlockingQueueConsumer(ArrayBlockingQueue<Integer> queue) {
 	@Override
 	public void run() {
 		try {
-			while(true){
-				System.out.println("consumer...");
-//				Thread.currentThread().join(10);
-//				System.out.println("Consumer: get " + queue.take() + " from queue...");
+			for(int i = 0; i < 100; i++){
+				Thread.currentThread().join(10);
+				System.out.println("Consumer: get " + queue.take() + " from queue...");
 				Thread.sleep(10);
 			}
 		} catch (InterruptedException e) {
@@ -23,10 +22,10 @@ public void run() {
 	}
 
 	public static void main(String[] args) throws InterruptedException {
-//		ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10000);
-		new Thread().run();
-		new Thread(()->{System.out.println("producer...");}).run();
-//		Thread.currentThread().join();
+		ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
+		new Thread(new ArrayBlockingQueueConsumer(queue)).start();
+		new Thread(new ArrayBlockingQueueProducer(queue)).start();
+		Thread.currentThread().join();
 		System.out.println("Finish...");
 	}
 }

Algorithm(4th_Edition)/src/ca/mcmaster/queue/arrayblockingqueue/ArrayBlockingQueueProducer.java

@@ -14,11 +14,9 @@ public ArrayBlockingQueueProducer(ArrayBlockingQueue<Integer> queue) {
 	public void run() {
 		while(true){
 			try {
-				System.out.println("producer...");
-				Thread.currentThread().join(10);
-//				queue.put(ai.getAndIncrement());
-//				System.out.println("Producer: put " + ai.get() + " into queue...");
-				Thread.sleep(10000);
+				queue.put(ai.getAndIncrement());
+				System.out.println("Producer: put " + ai.get() + " into queue...");
+				Thread.sleep(10);
 			} catch (InterruptedException e) {
 				e.printStackTrace();
 			}

DataStructrue/Queue/ArrayBlockingQueue.md

@@ -133,4 +133,71 @@
             lock.unlock();
         }
     }
-```
+```
+
+## Test
+* Producer
+Producer continuously put data into queue.
+```Java
+public class ArrayBlockingQueueProducer implements Runnable {
+	private ArrayBlockingQueue<Integer> queue;
+	public ArrayBlockingQueueProducer(ArrayBlockingQueue<Integer> queue) {
+		super();
+		this.queue = queue;
+	}
+	private volatile AtomicInteger ai = new AtomicInteger(0);
+	@Override
+	public void run() {
+		while(true){
+			try {
+				queue.put(ai.getAndIncrement());
+				System.out.println("Producer: put " + ai.get() + " into queue...");
+				Thread.sleep(10);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+}
+```
+
+* Consumer
+Consumer get take data from queue 100 times
+```Java
+public class ArrayBlockingQueueConsumer implements Runnable {
+	private ArrayBlockingQueue<Integer> queue;
+	public ArrayBlockingQueueConsumer(ArrayBlockingQueue<Integer> queue) {
+		super();
+		this.queue = queue;
+	}
+	@Override
+	public void run() {
+		try {
+			for(int i = 0; i < 100; i++){
+				Thread.currentThread().join(10);
+				System.out.println("Consumer: get " + queue.take() + " from queue...");
+				Thread.sleep(10);
+			}
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+	}
+
+	public static void main(String[] args) throws InterruptedException {
+		ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
+		new Thread(new ArrayBlockingQueueConsumer(queue)).start();
+		new Thread(new ArrayBlockingQueueProducer(queue)).start();
+		Thread.currentThread().join();
+		System.out.println("Finish...");
+	}
+}
+```
+* Result
+>...
+Producer: put 108 into queue...
+Consumer: get 98 from queue...
+Producer: put 109 into queue...
+Consumer: get 99 from queue...
+Producer: put 110 into queue...
+
+We can find that Producer is **blocked**.

DataStructrue/Queue/ArrayBlockingQueueConsumer.java

@@ -0,0 +1,31 @@
+package ca.mcmaster.queue.arrayblockingqueue;
+
+import java.util.concurrent.ArrayBlockingQueue;
+
+public class ArrayBlockingQueueConsumer implements Runnable {
+	private ArrayBlockingQueue<Integer> queue;
+	public ArrayBlockingQueueConsumer(ArrayBlockingQueue<Integer> queue) {
+		super();
+		this.queue = queue;
+	}
+	@Override
+	public void run() {
+		try {
+			for(int i = 0; i < 100; i++){
+				Thread.currentThread().join(10);
+				System.out.println("Consumer: get " + queue.take() + " from queue...");
+				Thread.sleep(10);
+			}
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+	}
+
+	public static void main(String[] args) throws InterruptedException {
+		ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
+		new Thread(new ArrayBlockingQueueConsumer(queue)).start();
+		new Thread(new ArrayBlockingQueueProducer(queue)).start();
+		Thread.currentThread().join();
+		System.out.println("Finish...");
+	}
+}

DataStructrue/Queue/ArrayBlockingQueueProducer.java

@@ -0,0 +1,25 @@
+package ca.mcmaster.queue.arrayblockingqueue;
+
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class ArrayBlockingQueueProducer implements Runnable {
+	private ArrayBlockingQueue<Integer> queue;
+	public ArrayBlockingQueueProducer(ArrayBlockingQueue<Integer> queue) {
+		super();
+		this.queue = queue;
+	}
+	private volatile AtomicInteger ai = new AtomicInteger(0);
+	@Override
+	public void run() {
+		while(true){
+			try {
+				queue.put(ai.getAndIncrement());
+				System.out.println("Producer: put " + ai.get() + " into queue...");
+				Thread.sleep(10);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+}