add multithread

Author: codingWang

src/com/duwei/multythread/util/CountDownLatchDemo.java

@@ -0,0 +1,52 @@
+package com.duwei.multythread.util;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * 使用CountDownLatch可以使其他任务执行完后再执行接下来的代码，相当于计数
+ */
+public class CountDownLatchDemo {
+    public static void main(String[] args) {
+        final CountDownLatch latch = new CountDownLatch(2);
+        new Thread() {
+            public void run() {
+                try {
+                    System.out.println("子线程" + Thread.currentThread().getName() + "正在执行");
+                    Thread.sleep(3000);
+                    System.out.println("子线程" + Thread.currentThread().getName() + "执行完毕");
+                    latch.countDown();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+
+            ;
+        }.start();
+
+        new Thread() {
+            public void run() {
+                try {
+                    System.out.println("子线程" + Thread.currentThread().getName() + "正在执行");
+                    Thread.sleep(3000);
+                    System.out.println("子线程" + Thread.currentThread().getName() + "执行完毕");
+                    latch.countDown();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+
+            ;
+        }.start();
+
+        try {
+            System.out.println("等待2个子线程执行完毕...");
+            latch.await();
+            System.out.println("2个子线程已经执行完毕");
+            System.out.println("继续执行主线程");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+}

src/com/duwei/multythread/util/CyclicBarrierDemo.java

@@ -0,0 +1,45 @@
+package com.duwei.multythread.util;
+
+import java.util.concurrent.BrokenBarrierException;
+import java.util.concurrent.CyclicBarrier;
+
+/**
+ * 字面意思回环栅栏，通过它可以实现让一组线程等待至某个状态之后再全部同时执行。
+ * 叫做回环是因为当所有等待线程都被释放以后，CyclicBarrier可以被重用。
+ * 我们暂且把这个状态就叫做barrier，当调用await()方法之后，线程就处于barrier了。
+ *
+ * http://www.importnew.com/21889.html
+ */
+public class CyclicBarrierDemo {
+
+    public static void main(String[] args) {
+        int N = 4;
+        CyclicBarrier barrier = new CyclicBarrier(N);
+        for (int i = 0; i < N; i++)
+            new Writer(barrier).start();
+    }
+
+    static class Writer extends Thread {
+        private CyclicBarrier cyclicBarrier;
+
+        public Writer(CyclicBarrier cyclicBarrier) {
+            this.cyclicBarrier = cyclicBarrier;
+        }
+
+        @Override
+        public void run() {
+            System.out.println("线程" + Thread.currentThread().getName() + "正在写入数据...");
+            try {
+                Thread.sleep(5000);      //以睡眠来模拟写入数据操作
+                System.out.println("线程" + Thread.currentThread().getName() + "写入数据完毕，等待其他线程写入完毕");
+                cyclicBarrier.await();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            } catch (BrokenBarrierException e) {
+                e.printStackTrace();
+            }
+            System.out.println("所有线程写入完毕，继续处理其他任务...");
+        }
+    }
+
+}

src/com/duwei/multythread/util/SemaphoreDemo.java

@@ -0,0 +1,46 @@
+package com.duwei.multythread.util;
+
+import java.util.concurrent.Semaphore;
+
+/**
+ * Semaphore翻译成字面意思为 信号量，Semaphore可以控同时访问的线程个数，
+ * 通过 acquire() 获取一个许可，如果没有就等待，而 release() 释放一个许可。
+ */
+public class SemaphoreDemo {
+
+    /**
+     * 假若一个工厂有5台机器，但是有8个工人，一台机器同时只能被一个工人使用，只有使用完了，
+     * 其他工人才能继续使用。那么我们就可以通过Semaphore来实现：
+     *
+     * @param args
+     */
+    public static void main(String[] args) {
+        int N = 8;            //工人数
+        Semaphore semaphore = new Semaphore(5); //机器数目
+        for (int i = 0; i < N; i++)
+            new Worker(i, semaphore).start();
+    }
+
+    static class Worker extends Thread {
+        private int num;
+        private Semaphore semaphore;
+
+        public Worker(int num, Semaphore semaphore) {
+            this.num = num;
+            this.semaphore = semaphore;
+        }
+
+        @Override
+        public void run() {
+            try {
+                semaphore.acquire();
+                System.out.println("工人" + this.num + "占用一个机器在生产...");
+                Thread.sleep(2000);
+                System.out.println("工人" + this.num + "释放出机器");
+                semaphore.release();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}

src/com/duweri/interview/ByteComput.java

@@ -0,0 +1,10 @@
+package com.duweri.interview;
+
+public class ByteComput {
+
+    public static void main(String[] args) {
+
+
+    }
+
+}

src/com/duweri/interview/sort/BubbleSort.java

@@ -1,6 +1,6 @@
 package com.duweri.interview.sort;
 
-public class BubbleSort extends BaseSortAlgorithms{
+public class BubbleSort extends BaseSortAlgorithms {
     /*
      * 冒泡排序
      * 比较相邻的元素。如果第一个比第二个大，就交换他们两个。