java - 如何使用来自我的 hashmap lmax 中断器的数据来完成 ringbuffer

Question

实际上，在阅读并使用了一个简单的破坏性示例之后，我找不到如何使用来自我的 hashmap 的数据完成我的环形缓冲区，这些数据已经由 eventHandler 、翻译器或哪个组件的数据完成？

Answer 1

你应该在你的bean或包含你的业务流程的地方做最简单的测试方法是在你的主类中

 public static void main () {

    // Executor that will be used to construct new threads for consumers
        Executor executor = Executors.newCachedThreadPool();

        // The factory for the event
        LogEventFactory factory = new LogEventFactory();

        // Specify the size of the ring buffer, must be power of 2.
        int bufferSize = 262144;

        // Construct the Disruptor
        Disruptor<LogEvent> disruptor = new Disruptor<LogEvent>(factory, bufferSize, executor);

        // Connect the handler
        disruptor.handleEventsWith(new LogEventHandler());

        // Start the Disruptor, starts all threads running
        disruptor.start();

        // Get the ring buffer from the Disruptor to be used for publishing.
        RingBuffer<LogEvent> ringBuffer = disruptor.getRingBuffer();

        LongEventProducerWithTranslator producer = new LongEventProducerWithTranslator(ringBuffer);

        **for (String name : cache.keySet()) {



            String key = name.toString();
            String value = cache.get(name).toString();

            producer.onData(cache.get(name));
            //Thread.sleep(2000);
            //System.out.println("key:" + key + " " + "//value:" + cache.get(name).getTags());

        }**

遍历它，你的翻译类应该接受通过循环的对象