成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

高性能的生產(chǎn)者-消費者新選擇：無鎖的緩存框架 Disruptor

姘擱『 / 1923人閱讀 

    
        com.lmax
        disruptor
        3.3.4

public class PCData {

private long value;

public long getValue() {
    return value;
}

public void setValue(long value) {
    this.value = value;
}

}

public class PCDataFactory implements EventFactory {

@Override
public PCData newInstance() {
    return new PCData();
}

}

public class Producer {

private final RingBuffer ringBuffer;

public Producer(RingBuffer ringBuffer) {
    this.ringBuffer = ringBuffer;
}

public void pushData(ByteBuffer byteBuffer){
    long sequence = ringBuffer.next();
    try{
        PCData event = ringBuffer.get(sequence);
        event.setValue(byteBuffer.getLong(0));
    }finally {
        ringBuffer.publish(sequence);
    }
}

}

public class Consumer implements WorkHandler {

@Override
public void onEvent(PCData pcData) throws Exception {
    System.out.println(Thread.currentThread().getName()+"Event:--"+pcData.getValue()*pcData.getValue()+"--");
}

}

public class App {

public static void main(String[] args) throws InterruptedException {
    ExecutorService executorService = Executors.newCachedThreadPool();
    PCDataFactory factory = new PCDataFactory();

    int bufferSize = 1024;
    Disruptor dataDisruptor = new Disruptor(factory,bufferSize,executorService,
            ProducerType.MULTI,new BlockingWaitStrategy());
    dataDisruptor.handleEventsWithWorkerPool(
            new Consumer(),
            new Consumer(),
            new Consumer(),
            new Consumer()
    );

    dataDisruptor.start();

    RingBuffer ringBuffer = dataDisruptor.getRingBuffer();
    Producer producer = new Producer(ringBuffer);
    ByteBuffer byteBuffer = ByteBuffer.allocate(8);
    for(long l=0;true;l++){
        byteBuffer.putLong(0,l);
        producer.pushData(byteBuffer);
        Thread.sleep(100);
        System.out.println("add data"+l);
    }
}

}

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

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/74762.html

相關(guān)文章

  • Spring整合Disruptor3

    摘要：我們知道是一個隊列，生產(chǎn)者往隊列里發(fā)布一項事件或稱之為消息也可以時，消費者能獲得通知如果沒有事件時，消費者被堵塞，直到生產(chǎn)者發(fā)布了新的事件。實戰(zhàn)本文先不具體去闡述的工作具體原理，只是簡單地將與其整合。 什么是Disruptor 從功能上來看，Disruptor 是實現(xiàn)了隊列的功能，而且是一個有界隊列。那么它的應(yīng)用場景自然就是生產(chǎn)者-消費者模型的應(yīng)用場合了。可以拿 JDK 的 Block...

    khs1994 評論0 收藏0

  • 高性能SPSC無鎖隊列設(shè)計之路

    摘要：當(dāng)多線程修改互相獨立的變量時，如果這些變量共享同一個緩存行，就會無意中影響彼此的性能，這就是偽共享。 序 本文整理了Single Producer/Consumer lock free Queue step by step這篇文章里頭關(guān)于高性能的SPSC無鎖隊列使用遵循的幾個原則： 單寫原則 使用lazySet替代volatile set 使用位運算替代取模運算 避免偽共享 減少緩存...

    evin2016 評論0 收藏0

  • JAVA多線程使用場景和注意事項

    摘要：一個是線程退出條件，一個是異常處理情況。很方便，每個線程一份數(shù)據(jù)，也很安全，但要注意內(nèi)存泄露。線程池參數(shù)包最常用的就是線程池，平常工作建議直接使用線程池，類就可以降低優(yōu)先級了。在線程池的構(gòu)造參數(shù)中，我們使用的隊列，一定要注意其特性和邊界。 我曾經(jīng)對自己的小弟說，如果你實在搞不清楚什么時候用HashMap，什么時候用ConcurrentHashMap，那么就用后者，你的代碼bug會很少。...

    Joyven 評論0 收藏0

  • 追蹤解析 Disruptor 源碼

    摘要：分段策略嘗試自旋此，然后調(diào)用次，如果經(jīng)過這兩百次的操作還未獲取到任務(wù)，就會嘗試階段性掛起自身線程。 零 前期準(zhǔn)備 0 FBI WARNING 文章異常啰嗦且繞彎。 1 版本 Disruptor 版本 : Disruptor 3.4.2 IDE : idea 2018.3 JDK 版本 : OpenJDK 11.0.1 2 Disruptor 簡介 高性能線程間消息隊列框架 Disrup...

    LiangJ 評論0 收藏0

  • 一次生產(chǎn) CPU 100% 排查優(yōu)化實踐

    摘要：發(fā)現(xiàn)這是的一個堆棧，前段時間正好解決過一個由于隊列引起的一次強如也發(fā)生內(nèi)存溢出沒想到又來一出。因此初步判斷為大量線程執(zhí)行函數(shù)之后互相競爭導(dǎo)致使用率增高，而通過對堆棧發(fā)現(xiàn)是和使用有關(guān)。 showImg(https://segmentfault.com/img/remote/1460000017395756?w=1816&h=1080); 前言 到了年底果然都不太平，最近又收到了運維報警：...

    roundstones 評論0 收藏0

發(fā)表評論

0條評論

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