Disruptor学習(1)

Disruptorはオープンソースの同時フレームワークであり、2011 Duke'sプログラムフレームワーク革新賞を受賞し、ロックなしでネットワークのQueue同時操作を実現することができる.彼の例をあげましょう.絶対にhello worlレベルです.2つのクラスしかありません.1つは実行クラスで、1つは自分で定義したクラスです.自分でeventクラスを定義する必要があります.

package com.trevorbernard.disruptor.examples;

import com.lmax.disruptor.EventFactory;

/**
 * WARNING: This is a mutable object which will be recycled by the RingBuffer. You must take a copy of data it holds
 * before the framework recycles it.
 */
public final class ValueEvent {
    private String value;

    public String getValue() {
        return value;
    }

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

    public final static EventFactory<ValueEvent> EVENT_FACTORY = new EventFactory<ValueEvent>() {
        public ValueEvent newInstance() {
            return new ValueEvent();
        }
    };
}

ここでfactoryクラスを使用します.定義されたクラスを生成します.クラスを実行します.

package com.trevorbernard.disruptor.examples;

import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.dsl.Disruptor;

public class Simple {
    @SuppressWarnings("unchecked")
    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
        // Preallocate RingBuffer with 1024 ValueEvents
        Disruptor<ValueEvent> disruptor = new Disruptor<ValueEvent>(ValueEvent.EVENT_FACTORY, 1024, exec);
        final EventHandler<ValueEvent> handler = new EventHandler<ValueEvent>() {
            // event will eventually be recycled by the Disruptor after it wraps
            public void onEvent(final ValueEvent event, final long sequence, final boolean endOfBatch) throws Exception {
                System.out.println("Sequence: " + sequence+"   ValueEvent: " + event.getValue());
            }
        };

        disruptor.handleEventsWith(handler);
        RingBuffer<ValueEvent> ringBuffer = disruptor.start();
        for (long i = 10; i < 15; i++) {
            String uuid =String.valueOf(i)    ;
            long seq = ringBuffer.next();
            ValueEvent valueEvent = ringBuffer.get(seq);
            valueEvent.setValue(uuid);
            ringBuffer.publish(seq);
        }
        disruptor.shutdown();
        exec.shutdown();
    }
}

イベントのリスニングを設定します.ここでは印刷するだけです.それから私たちが定義したイベントをRingBufferに書き込んで、発表します.リスニングを担当する人は受け入れます.プロセス全体は非常に簡単です.添付ファイルはソースコードです.