真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯網站制作重慶分公司

linkedblockingqueue如何在java中使用

本篇文章為大家展示了linkedblockingqueue如何在java中使用,內容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細介紹希望你能有所收獲。

我們提供的服務有:成都網站設計、成都網站建設、外貿網站建設、微信公眾號開發(fā)、網站優(yōu)化、網站認證、汾陽ssl等。為上千多家企事業(yè)單位解決了網站和推廣的問題。提供周到的售前咨詢和貼心的售后服務,是有科學管理、有技術的汾陽網站制作公司

Java的特點有哪些

Java的特點有哪些 1.Java語言作為靜態(tài)面向對象編程語言的代表,實現了面向對象理論,允許程序員以優(yōu)雅的思維方式進行復雜的編程。 2.Java具有簡單性、面向對象、分布式、安全性、平臺獨立與可移植性、動態(tài)性等特點。 3.使用Java可以編寫桌面應用程序、Web應用程序、分布式系統(tǒng)和嵌入式系統(tǒng)應用程序等。

1.put方法使用事項

(1)使用putLock加鎖;

(2)如果隊列滿了就阻塞在notFull條件上;

(3)否則就入隊;

(4)如果入隊后元素數量小于容量,喚醒其它阻塞在notFull條件上的線程;

(5)釋放鎖;

(6)如果放元素之前隊列長度為0,就喚醒notEmpty條件;

2.put增加元素實例

 public void put(E e) throws InterruptedException {
        if (e == null) throw new NullPointerException();   //e不能為null
        int c = -1;
        Node node = new Node(e);
        final ReentrantLock putLock = this.putLock;     //獲取put鎖
        final AtomicInteger count = this.count;          //獲取count
        putLock.lockInterruptibly();
        try {
            while (count.get() == capacity) {        //如果滿了,那么就需要使用notFull阻塞
                notFull.await();
            }
            enqueue(node);
            c = count.getAndIncrement();
            if (c + 1 < capacity)                    //如果此時又有空間了,那么notFull喚醒
                notFull.signal();
        } finally {
            putLock.unlock();             //釋放鎖
        }
        if (c == 0)            //當c為0時候,也要根take鎖說一下,并發(fā)下
            signalNotEmpty();        //調用notEmpty        
    }
public E take() throws InterruptedException {
    E x;
    int c = -1;
    final AtomicInteger count = this.count;
    final ReentrantLock takeLock = this.takeLock;
    // 使用takeLock加鎖
    takeLock.lockInterruptibly();
    try {
        // 如果隊列無元素,則阻塞在notEmpty條件上
        while (count.get() == 0) {
            notEmpty.await();
        }
        // 否則,出隊
        x = dequeue();
        // 獲取出隊前隊列的長度
        c = count.getAndDecrement();
        // 如果取之前隊列長度大于1,則喚醒notEmpty
        if (c > 1)
            notEmpty.signal();
    } finally {
        // 釋放鎖
        takeLock.unlock();
    }
    // 如果取之前隊列長度等于容量
    // 則喚醒notFull
    if (c == capacity)
        signalNotFull();
    return x;
}
 
private E dequeue() {
    // head節(jié)點本身是不存儲任何元素的
    // 這里把head刪除,并把head下一個節(jié)點作為新的值
    // 并把其值置空,返回原來的值
    Node h = head;
    Node first = h.next;
    h.next = h; // help GC
    head = first;
    E x = first.item;
    first.item = null;
    return x;
}
 
private void signalNotFull() {
    final ReentrantLock putLock = this.putLock;
    putLock.lock();
    try {
        // 喚醒notFull
        notFull.signal();
    } finally {
        putLock.unlock();
    }
}

上述內容就是linkedblockingqueue如何在java中使用,你們學到知識或技能了嗎?如果還想學到更多技能或者豐富自己的知識儲備,歡迎關注創(chuàng)新互聯行業(yè)資訊頻道。


分享標題:linkedblockingqueue如何在java中使用
路徑分享:http://weahome.cn/article/jsisip.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部