update

Author: kimmking

03concurrency/0301/src/main/java/java0/conc0302/atomic/AtomicMain.java

@@ -4,7 +4,7 @@
 public class AtomicMain {
 
     public static void main(String[] args) {
-        final AtomicCount count = new AtomicCount();
+        final SyncCount count = new SyncCount();
         for (int i = 0; i < 100; i++) {
             new Thread(new Runnable() {
                 @Override
@@ -17,7 +17,7 @@ public void run() {
         }
 
         try {
-            Thread.sleep(1000L);
+            Thread.sleep(5000L);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }

03concurrency/0301/src/main/java/java0/conc0302/atomic/SyncCount.java

@@ -1,12 +1,22 @@
 
 package java0.conc0302.atomic;
 
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
 public class SyncCount {
 
     private int num = 0;
 
-    public synchronized int add() {
-        return num++;
+    private Lock lock = new ReentrantLock(true);
+
+    public int add() {
+        try {
+            lock.lock();
+            return num++;
+        } finally {
+            lock.unlock();
+        }
     }
 
     public int getNum() {

03concurrency/0301/src/main/java/java0/conc0302/lock/TestFair.java

@@ -0,0 +1,38 @@
+package java0.conc0302.lock;
+
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class TestFair {
+    public static volatile int race=0;
+    public static ReentrantLock lock = new ReentrantLock(true); // 改成false会好100倍
+    public static void increase(){
+        lock.lock();
+        race++;    //变量自增操作
+        lock.unlock();
+    }
+    private static final int THREADS_COUNT=20;
+    public static void main(String[]args){
+        int count = Thread.activeCount();
+        long now = System.currentTimeMillis();
+        System.out.println(count);
+        AtomicReference<Thread> sign =new AtomicReference<>();
+        Thread[]threads=new Thread[THREADS_COUNT];  //定义20个线程
+        for(int i=0;i<THREADS_COUNT;i++){
+            threads[i]=new Thread(new Runnable(){
+                @Override
+                public void run(){
+                    for(int i=0;i<100000;i++){
+                        increase();
+                    }
+                }
+            });
+            threads[i].start();
+        }//等待所有累加线程都结束
+        while(Thread.activeCount()>count) {
+            Thread.yield();
+        }
+        System.out.println(lock.getClass().getName() + " ts = "+ (System.currentTimeMillis()-now));
+    }
+}
+

03concurrency/0301/src/main/java/java0/conc0302/threadpool/ExceptionDemo.java

@@ -21,16 +21,16 @@ public static void main(String[] args) {
             System.out.println("catch submit");
             ex.printStackTrace();
         }
-        
-        try {
-            executorService.execute(() -> {
-                  throw new RuntimeException("executorService.execute()");
-                });
-        } catch (Exception ex) {
-            System.out.println("catch execute");
-            ex.printStackTrace();
-        }
-        
+//
+//        try {
+//            executorService.execute(() -> {
+//                  throw new RuntimeException("executorService.execute()");
+//                });
+//        } catch (Exception ex) {
+//            System.out.println("catch execute");
+//            ex.printStackTrace();
+//        }
+//
         executorService.shutdown();
         System.out.println("Main Thread End!");
     }

03concurrency/0301/src/main/java/java0/conc0303/tool/CountDownLatchDemo.java

@@ -5,7 +5,7 @@
 public class CountDownLatchDemo {
     public static void main(String[] args) throws InterruptedException {
         CountDownLatch countDownLatch = new CountDownLatch(5);
-        for(int i=0;i<10;i++){
+        for(int i=0;i<5;i++){
             new Thread(new readNum(i,countDownLatch)).start();
         }
         countDownLatch.await(); // 注意跟CyclicBarrier不同，这里在主线程await

03concurrency/0301/src/main/java/java0/conc0303/tool/CyclicBarrierDemo.java

@@ -39,9 +39,9 @@ public void run() {
             synchronized (this){
                 System.out.println("id:"+id+","+Thread.currentThread().getName());
                 try {
-                    //cyc.await();
+                    cyc.await();
                     System.out.println("线程组任务" + id + "结束，其他任务继续");
-                    cyc.await();   // 注意跟CountDownLatch不同，这里在子线程await
+                    //cyc.await();   // 注意跟CountDownLatch不同，这里在子线程await
                 } catch (Exception e) {
                     e.printStackTrace();
                 }

03concurrency/0301/src/main/java/java0/conc0303/tool/SemaphoreDemo.java

@@ -6,7 +6,7 @@ public class SemaphoreDemo {
 
     public static void main(String[] args) {
         int N = 8;            //工人数
-        Semaphore semaphore = new Semaphore(1); //机器数目
+        Semaphore semaphore = new Semaphore(2); //机器数目
         for (int i = 0; i < N; i++)
             new Worker(i, semaphore).start();
     }