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

姘擱『發布于2019-08-16 17:49 / 1915人閱讀

    
        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);
    }
}

}

云服務器 GPU云服務器生產者消費者生產者消費者問題線程java生產者消費者 java生產者消費

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/74762.html

Spring整合Disruptor3

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

khs1994 2019-08-15 15:32 評論0 收藏0
高性能SPSC無鎖隊列設計之路

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

evin2016 2019-08-16 10:44 評論0 收藏0
JAVA多線程使用場景和注意事項

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

Joyven 2019-08-16 15:48 評論0 收藏0
追蹤解析 Disruptor 源碼

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

LiangJ 2019-08-16 15:03 評論0 收藏0
一次生產 CPU 100% 排查優化實踐

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

roundstones 2019-08-16 14:00 評論0 收藏0