From 1bd6a27a44aa50e7614eb79446a3ce86f497908e Mon Sep 17 00:00:00 2001 From: kuangcp Date: Tue, 24 Sep 2024 16:47:49 +0800 Subject: [PATCH] doc --- .../github/kuangcp/queue/disruptor/first/FirstTest.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/concurrency/src/test/java/com/github/kuangcp/queue/disruptor/first/FirstTest.java b/concurrency/src/test/java/com/github/kuangcp/queue/disruptor/first/FirstTest.java index ba3b3ff..c788b6a 100644 --- a/concurrency/src/test/java/com/github/kuangcp/queue/disruptor/first/FirstTest.java +++ b/concurrency/src/test/java/com/github/kuangcp/queue/disruptor/first/FirstTest.java @@ -104,7 +104,7 @@ public void testConsumerChain() throws Exception { /** - * 多生产者 多消费者 + * 多生产者 多消费者（长耗时） */ @Test public void testProductConsumerSlow() throws Exception { @@ -118,17 +118,18 @@ public void testProductConsumerSlow() throws Exception { ); // 有多少个消费者就会创建多少线程去执行消费，此时会创建三个线程 disruptor - .handleEventsWithWorkerPool(new OrderEventSlowHandler("a"), new OrderEventSlowHandler("b")) + .handleEventsWithWorkerPool(new OrderEventSlowHandler("a1"), new OrderEventSlowHandler("a2"), new OrderEventSlowHandler("a3")) .then(new OrderEventSlowHandler("c")); disruptor.start(); RingBuffer ringBuffer = disruptor.getRingBuffer(); OrderEventProducer eventProducer = new OrderEventProducer(ringBuffer); // 创建一个线程池，模拟多个生产者 ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10); - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 30; i++) { fixedThreadPool.execute(() -> eventProducer.onData(UUID.randomUUID().toString())); } + // 注意当所有消息都被消费后，消费者线程会进入无休止的CAS，导致CPU占用率高企 Thread.currentThread().join(); } }