1.1.1 類Semaphore的同步性

多線程中的同步概念其實就是排著隊去執行一個任務，執行任務是一個一個執行，并不能并行執行，這樣的優點是有助于程序邏輯的正確性，不會出現非線程安全問題，保證軟件系統功能上的運行穩定性。

那么本節就使用一個初步的案例來看看Semaphore類是如何實現限制線程并發數的。

創建實驗用的項目SemaphoreTest1，類Service.java代碼如下：

---

        package service;
        import java.util.concurrent.Semaphore;
        public class Service {
            private Semaphore semaphore = new Semaphore(1);
            public void testMethod() {
                try {
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName()
                                  + " begin timer=" + System.currentTimeMillis());
                          Thread.sleep(5000);
                          System.out.println(Thread.currentThread().getName()
                                  + "    end timer=" + System.currentTimeMillis());
                          semaphore.release();
                      } catch (InterruptedException e) {
                          e.printStackTrace();
                      }
                  }
            }

---

類Semaphore的構造函數參數permits是許可的意思，代表同一時間內，最多允許多少個線程同時執行acquire()和release()之間的代碼。

無參方法acquire()的作用是使用1個許可，是減法操作。

創建3個線程類如圖1-3所示。

運行類Run.java代碼如下：

---

        package test;
        import service.Service;
        import extthread.ThreadA;
        import extthread.ThreadB;
        import extthread.ThreadC;
        public class Run {
            public static void main(String[] args) {
                Service service = new Service();
                ThreadA a = new ThreadA(service);
                a.setName("A");
                ThreadB b = new ThreadB(service);
                b.setName("B");
                ThreadC c = new ThreadC(service);
                c.setName("C");
                a.start();
                b.start();
        c.start();
    }
}

---

程序運行后的效果如圖1-4所示。

說明使用代碼：

---

        private Semaphore semaphore = new Semaphore(1);

---

來定義最多允許1個線程執行acquire()和release()之間的代碼，所以打印的結果就是3個線程是同步的。