增加CountDownLatch实例

Author: chenssy89

javaConcurrency/src/com/concurrency/CountDownLatch/Conference.java

@@ -0,0 +1,48 @@
+package com.concurrency.CountDownLatch;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * 
+ * @Project:javaConcurrency
+ * @file:Conference.java
+ *
+ * @Author:chenssy
+ * @email:[email protected]
+ * @url : http://cmsblogs.com
+ * @qq : 122448894
+ *
+ * @data:2015年9月6日
+ */
+public class Conference implements Runnable{
+	private final CountDownLatch countDown;
+	
+	public Conference(int count){
+		countDown = new CountDownLatch(count);
+	}
+	
+	/**
+	 * 与会人员到达，调用arrive方法，到达一个CountDownLatch调用countDown方法，锁计数器-1
+	 * @author:chenssy
+	 * @data:2015年9月6日
+	 *
+	 * @param name
+	 */
+	public void arrive(String name){
+		System.out.println(name + "到达.....");
+		//调用countDown()锁计数器 - 1
+		countDown.countDown();
+		System.out.println("还有 " + countDown.getCount() + "没有到达...");
+	}
+	
+	@Override
+	public void run() {
+		System.out.println("准备开会，参加会议人员总数为：" + countDown.getCount());
+		//调用await()等待所有的与会人员到达
+		try {
+			countDown.await();
+		} catch (InterruptedException e) {
+		}
+		System.out.println("所有人员已经到达，会议开始.....");
+	}
+}

javaConcurrency/src/com/concurrency/CountDownLatch/Participater.java

@@ -0,0 +1,16 @@
+package com.concurrency.CountDownLatch;
+
+public class Participater implements Runnable{
+	private String name;
+	private Conference conference;
+	
+	public Participater(String name,Conference conference){
+		this.name = name;
+		this.conference = conference;
+	}
+
+	@Override
+	public void run() {
+		conference.arrive(name);
+	}
+}

javaConcurrency/src/com/concurrency/CountDownLatch/Test.java

@@ -0,0 +1,15 @@
+package com.concurrency.CountDownLatch;
+
+public class Test {
+	public static void main(String[] args) {
+		//启动会议室线程，等待与会人员参加会议
+		Conference conference = new Conference(3);
+		new Thread(conference).start();
+		
+		for(int i = 0 ; i < 3 ; i++){
+			Participater participater = new Participater("chenssy-0" + i , conference);
+			Thread thread = new Thread(participater);
+			thread.start();
+		}
+	}
+}

javaConcurrency/src/com/concurrency/Semaphore/Job.java

@@ -1,5 +1,17 @@
 package com.concurrency.Semaphore;
 
+/**
+ * 
+ * @Project:javaConcurrency
+ * @file:Job.java
+ *
+ * @Author:chenssy
+ * @email:[email protected]
+ * @url : http://cmsblogs.com
+ * @qq : 122448894
+ *
+ * @data:2015Äê9ÔÂ6ÈÕ
+ */
 public class Job implements Runnable{
 	private PrintQueue printQueue;
 

javaConcurrency/src/com/concurrency/Semaphore/PrintQueue.java

@@ -2,6 +2,18 @@
 
 import java.util.concurrent.Semaphore;
 
+/**
+ * 打印任务
+ * @Project:javaConcurrency
+ * @file:PrintQueue.java
+ *
+ * @Author:chenssy
+ * @email:[email protected]
+ * @url : http://cmsblogs.com
+ * @qq : 122448894
+ *
+ * @data:2015年9月6日
+ */
 public class PrintQueue {
 	private final Semaphore semaphore;   //声明信号量
 

javaConcurrency/src/com/concurrency/Semaphore/Test.java

@@ -2,15 +2,15 @@
 
 public class Test {
 	public static void main(String[] args) {
-		Thread[] threads = new Thread[10];
+		Thread[] threads = new Thread[5];
 
 		PrintQueue printQueue = new PrintQueue();
 
-		for(int i = 0 ; i < 10 ; i++){
+		for(int i = 0 ; i < 5 ; i++){
 			threads[i] = new Thread(new Job(printQueue),"Thread_" + i);
 		}
 
-		for(int i = 0 ; i < 10 ; i++){
+		for(int i = 0 ; i < 5 ; i++){
 			threads[i].start();
 		}
 	}