国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

聊聊Java里常用的并發(fā)集合

番茄西紅柿 / 2654人閱讀

摘要:下面列出來一些常用的方法。延遲元素線程安全列表里面存放著帶有日期的元素,當(dāng)我們從列表獲取數(shù)據(jù)的時(shí)候,未到時(shí)間的元素將會被忽略。

前言

在我們的程序開發(fā)過程中,如果涉及到多線程環(huán)境,那么對于集合框架的使用就必須更加謹(jǐn)慎了,因?yàn)榇蟛糠值募项愒诓皇┘宇~外控制的情況下直接在并發(fā)環(huán)境中直接使用可能會出現(xiàn)數(shù)據(jù)不一致的問題,所以為了解決這個(gè)潛在的問題,我們要么在自己的業(yè)務(wù)邏輯中加上一些額外的控制,例如,或者我們直接使用Java提供的可在并發(fā)環(huán)境中使用的集合類,這是一個(gè)簡便而且高效的方法。那么我們下面就來了解下Java提供了哪些“神器”可以讓我們安全的使用集合。

正文

非阻塞式安全列表 - ConcurrentLinkedDeque

ConcurrentLinkedDeque可以在并發(fā)環(huán)境中直接使用,所謂的非阻塞,就是當(dāng)列表為空的時(shí)候,我們還繼續(xù)從列表中取數(shù)據(jù)的話,它會直接返回null或者拋出異常。下面列出來一些常用的方法。

peekFirst()peekLast() :返回列表中首位跟末尾元素,如果列表為空則返回null。返回的元素不從列表中刪除。

getFirst()getLast() :返回列表中首位跟末尾元素,如果列表為空則拋出NoSuchElementExceotion異常。返回的元素不從列表中刪除。

removeFirst()removeLast() :返回列表中首位跟末尾元素,如果列表為空則拋出NoSuchElementExceotion異常。【返回的元素會從列表中刪除】。

阻塞式安全列表 - LinkedBlockingDeque

LinkedBlockingDeque是一個(gè)阻塞式的線程安全列表,它跟 ConcurrentLinkedDeque最大的區(qū)別就是,當(dāng)列表中元素滿了或者為空的時(shí)候,我們對該列表的操作不會立即返回,而是阻塞當(dāng)前操作,直到該操作可以執(zhí)行時(shí)才返回。我們對比著上面ConcurrentLinkedDeque的常用方法,來看下LinkedBlockingDeque會有哪些不一致的地方呢?

put() :插入元素至列表中,當(dāng)表中元素已滿的時(shí)候,該操作將會被阻塞,直到表中存在空余空間。

take() : 從列表中獲取元素,當(dāng)列表為空,該操作會被阻塞,直到列表不為空。

peekFirst()peekLast() :返回列表中首位跟末尾元素,如果列表為空則返回null。返回的元素不從列表中刪除。

getFirst()getLast() :返回列表中首位跟末尾元素,如果列表為空則拋出NoSuchElementExceotion異常。返回的元素不從列表中刪除。

addFirst()addLast() :將元素添加至首位跟末尾,如果列表已滿,則會拋出IllegalStateException

可以看出不管是從獲取還是插入元素,都多了不少“花樣”,其差別就在于是否阻塞,不滿足條件是否返回null,不滿足條件是否拋異常這幾個(gè)方面來區(qū)分。

優(yōu)先級排序阻塞式安全列表 - PriorityBlockingQueue

相信大家都寫過把某個(gè)列表元素按照特定的規(guī)則來排序之類的代碼,在PriorityBlockingQueue中,存放進(jìn)去的元素必須要實(shí)現(xiàn)Comparable接口。在這個(gè)接口中,有一個(gè)compareTo()方法,當(dāng)執(zhí)行該方法的對象跟參數(shù)傳入的對象進(jìn)行比較的時(shí)候,這個(gè)方法會返回一個(gè)數(shù)字值,如果值小于0,則當(dāng)前對象小于參數(shù)傳入對象。大于0則相反,等于0就表示兩個(gè)對象相等。

public class DemoObj implements Comparable<DemoObj> {
   
    private int priority;
    
    @Override
    public int compareTo(DemoObj do){
        if(this.getPriority() > do.getPriority()){
            return -1;
        }else if(this.getPriority() < do.getPriority()){
            return 1;
        }
        return 0;
    }
    
    //省略getset ...
}


//==== use ===================

PriorityBlockingQueue queue = new PriorityBlockingQueue()<>;
queue.put(DemoObj);
queue.peek();

其常用方法跟上面提到的類基本都差不多大家可以動手實(shí)現(xiàn)一下,簡單對比的話,可以說是LinkedBlockingDeque的增強(qiáng)版,多了元素排序功能。

延遲元素線程安全列表 - DelayQueue

DelayQueue 里面存放著帶有日期的元素,當(dāng)我們從列表獲取數(shù)據(jù)的時(shí)候,未到時(shí)間的元素將會被忽略。因此,存放進(jìn)來的元素必須實(shí)現(xiàn)Delayed接口,使之成為一個(gè)延遲對象。

/**
 *  compareTo方法與getDelay方法需排序一致
 */
class Order implements Delayed{

    private String name ;
    private long start = System.currentTimeMillis();
    private long time ;

    public MyDelayedTask(String name,long time) {
        this.name = name;
        this.time = time;
    }

    /**
     * 需要實(shí)現(xiàn)的接口,獲得延遲時(shí)間   用過期時(shí)間-當(dāng)前時(shí)間
     * @param unit
     * @return
     */
    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert((start+time) - System.currentTimeMillis(),TimeUnit.MILLISECONDS);
    }

    /**
     * 延遲隊(duì)列內(nèi)部排序   當(dāng)前對象延遲時(shí)間 - 入?yún)ο蟮难舆t時(shí)間
     * @param o
     * @return
     */
    @Override
    public int compareTo(Delayed o) {
        Order o1 = (Order) o;
        return (int) (this.getDelay(TimeUnit.MILLISECONDS) - o1.getDelay(TimeUnit.MILLISECONDS));
    }
}

使用方式如下

    private static DelayQueue delayQueue  = new DelayQueue();
    public static void main(String[] args) throws InterruptedException {

        new Thread(new Runnable() {
            @Override
            public void run() {

                delayQueue.offer(new Order("t3000",3000));
                delayQueue.offer(new Order("t4000",4000));
                delayQueue.offer(new Order("t2000",2000));
                delayQueue.offer(new Order("t6000",6000));
                delayQueue.offer(new Order("t1000",1000));

            }
        }).start();

        while (true) {
            Delayed take = delayQueue.take();
        }
    }

關(guān)于結(jié)果的輸出大家可以動手嘗試一下~

結(jié)語

這里僅僅是介紹了幾種常用的并發(fā)集合,其目的主要是讓大家對這些集合有一個(gè)直觀的認(rèn)識,在使用的時(shí)候可以思考下自己的場景用哪種更合適,如果當(dāng)前介紹的類沒合適的,那么是否還有其他并發(fā)集合會更有用呢?這里就當(dāng)做拋磚引玉吧,有興趣的朋友可以多去了解一下相關(guān)技術(shù),相信你會有不少收獲的。


公眾號博文同步Github倉庫,有興趣的朋友可以幫忙給個(gè)Star哦,碼字不易,感謝支持。

github.com/PeppaLittle…

推薦閱讀

《如何優(yōu)化代碼中大量的if/else,switch/case); 《如何提高使用Java反射的效率?》
《Java日志正確使用姿勢》

有收獲的話,就點(diǎn)個(gè)贊吧

關(guān)注「深夜里的程序猿」,分享最干的干貨

文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址:http://specialneedsforspecialkids.com/yun/7147.html

相關(guān)文章

  • 聊聊Java常用并發(fā)集合

    摘要:下面列出來一些常用的方法。延遲元素線程安全列表里面存放著帶有日期的元素,當(dāng)我們從列表獲取數(shù)據(jù)的時(shí)候,未到時(shí)間的元素將會被忽略。 前言 在我們的程序開發(fā)過程中,如果涉及到多線程環(huán)境,那么對于集合框架的使用就必須更加謹(jǐn)慎了,因?yàn)榇蟛糠值募项愒诓皇┘宇~外控制的情況下直接在并發(fā)環(huán)境中直接使用可能會出現(xiàn)數(shù)據(jù)不一致的問題,所以為了解決這個(gè)潛在的問題,我們要么在自己的業(yè)務(wù)邏輯中加上一些額外的控制,例如鎖...

    番茄西紅柿 評論0 收藏0
  • 聊聊Java常用并發(fā)集合

    摘要:下面列出來一些常用的方法。延遲元素線程安全列表里面存放著帶有日期的元素,當(dāng)我們從列表獲取數(shù)據(jù)的時(shí)候,未到時(shí)間的元素將會被忽略。 前言 在我們的程序開發(fā)過程中,如果涉及到多線程環(huán)境,那么對于集合框架的使用就必須更加謹(jǐn)慎了,因?yàn)榇蟛糠值募项愒诓皇┘宇~外控制的情況下直接在并發(fā)環(huán)境中直接使用可能會出現(xiàn)數(shù)據(jù)不一致的問題,所以為了解決這個(gè)潛在的問題,我們要么在自己的業(yè)務(wù)邏輯中加上一些額外的控制,例如鎖...

    ztyzz 評論0 收藏0
  • 聊聊面試中關(guān)于并發(fā)問題應(yīng)對方案

    摘要:這里呢,我直接給出高并發(fā)場景通常都會考慮的一些解決思路和手段結(jié)尾如何有效的準(zhǔn)備面試中并發(fā)類問題,我已經(jīng)給出我的理解。 showImg(https://segmentfault.com/img/bV7Viy?w=550&h=405); 主題 又到面試季了,從群里,看到許多同學(xué)分享了自己的面試題目,我也抽空在網(wǎng)上搜索了一些許多公司使用的面試題,目前校招和社招的面試題基本都集中在幾個(gè)大方向上...

    xzavier 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<