国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

java筆記--對信號量Semaphore的理解與運用

2019-11-14 20:52:08
字體:
來源:轉載
供稿:網友
java筆記--對信號量Semaphore的理解與運用

java Semaphore 信號量的使用:

在java中,提供了信號量Semaphore的支持。

Semaphore類是一個計數信號量,必須由獲取它的線程釋放, 通常用于限制可以訪問某些資源(物理或邏輯的)線程數目。

一個信號量有且僅有3種操作,且它們全部是原子的:初始化、增加和減少 增加可以為一個進程解除阻塞; 減少可以讓一個進程進入阻塞。

--如果朋友您想轉載本文章請注明轉載地址"http://m.survivalescaperooms.com/XHJT/p/3910406.html"謝謝--

信號量維護一個許可集,若有必要,會在獲得許可之前阻塞每一個線程: //從此信號量獲取給定數目的許可,在提供這些許可前一直將線程阻塞。 acquireUninterruptibly(int permits){} 每一個release()添加一個許可,從而可能釋放一個正在阻塞的獲取者。 Semaphore只對可用許可的號碼進行計數,并采取相應的行動。 如何獲得Semaphore對象? public Semaphore(int permits,boolean fair) permits:初始化可用的許可數目。 fair: 若該信號量保證在征用時按FIFO的順序授予許可,則為true,否則為false; 如何從信號量獲得許可? public void acquire() throws InterruptedException

如何釋放一個許可,并返回信號量? public void release() 代碼實例: 20個人去銀行存款,但是該銀行只有兩個辦公柜臺,有空位則上去存錢,沒有空位則只能去排隊等待

package com.xhj.thread;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Semaphore;/** * 線程信號量Semaphore的運用 *  * @author XIEHEJUN *  */public class SemaphoreThread {    PRivate int a = 0;    /**     * 銀行存錢類     */    class Bank {        private int account = 100;        public int getAccount() {            return account;        }        public void save(int money) {            account += money;        }    }    /**     * 線程執行類,每次存10塊錢     */    class NewThread implements Runnable {        private Bank bank;        private Semaphore semaphore;        public NewThread(Bank bank, Semaphore semaphore) {            this.bank = bank;            this.semaphore = semaphore;        }        @Override        public void run() {            int b = a++;            if (semaphore.availablePermits() > 0) {                System.out.println("線程" + b + "啟動,進入銀行,有位置立即去存錢");            } else {                System.out.println("線程" + b + "啟動,進入銀行,無位置,去排隊等待等待");            }            try {                semaphore.acquire();                bank.save(10);                System.out.println(b + "賬戶余額為:" + bank.getAccount());                Thread.sleep(1000);                System.out.println("線程" + b + "存錢完畢,離開銀行");                semaphore.release();            } catch (InterruptedException e) {                e.printStackTrace();            }        }    }    /**     * 建立線程,調用內部類,開始存錢     */    public void useThread() {        Bank bank = new Bank();        // 定義10個新號量        Semaphore semaphore = new Semaphore(2);        // 建立一個緩存線程池        ExecutorService es = Executors.newCachedThreadPool();        // 建立20個線程        for (int i = 0; i < 10; i++) {            // 執行一個線程            es.submit(new Thread(new NewThread(bank, semaphore)));        }        // 關閉線程池        es.shutdown();        // 從信號量中獲取兩個許可,并且在獲得許可之前,一直將線程阻塞        semaphore.acquireUninterruptibly(2);        System.out.println("到點了,工作人員要吃飯了");        // 釋放兩個許可,并將其返回給信號量        semaphore.release(2);    }    public static void main(String[] args) {        SemaphoreThread test = new SemaphoreThread();        test.useThread();    }}

面試題思考: 在很多情況下,可能有多個線程需要訪問數目很少的資源。假想在服務器上運行著若干個回答客戶端請求的線程。這些線程需要連接到同一數據庫,但任一時刻 只能獲得一定數目的數據庫連接。你要怎樣才能夠有效地將這些固定數目的數據庫連接分配給大量的線程? 答:1.給方法加同步鎖,保證同一時刻只能有一個人去調用此方法,其他所有線程排隊等待,但是此種情況下即使你的數據庫鏈接有10個,也始終只有一個處于使

用狀態。這樣將會大大的浪費系統資源,而且系統的運行效率非常的低下。

2.另外一種方法當然是使用信號量,通過信號量許可與數據庫可用連接數相同的數目,將大大的提高效率和性能。


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 连山| 宁晋县| 竹溪县| 临沭县| 高密市| 社会| 新河县| 金平| 施秉县| 武宁县| 兰坪| 兖州市| 礼泉县| 合作市| 祁门县| 鱼台县| 锡林郭勒盟| 台北市| 巴中市| 桑植县| 卓资县| 海林市| 九寨沟县| 旌德县| 新宾| 宿松县| 莱阳市| 彝良县| 本溪市| 莒南县| 宜城市| 同德县| 西乌| 徐州市| 新源县| 都江堰市| 甘孜| 朔州市| 凤山县| 同心县| 泰安市|