딜레이큐(delay queue) 테스트중 이런 에러가 발생했습니다.

Question

import java.util.concurrent.BlockingQueue; import java.util.concurrent.DelayQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import org.junit.Test; import static org.testng.Assert.assertEquals; public class DelayQueuetest { @Test public void givenDelayQueue_whenProduceElement_thenShouldConsumeAfterGivenDealy () throws InterruptedException{ // given ExecutorService executor = Executors.newFixedThreadPool(2); BlockingQueue queue = new DelayQueue<>(); int numberOfElementsToProduce = 2; int delayOfEachProduceMessageMilliseconds = 500; DelayQueueConsumer consumer = new DelayQueueConsumer( queue, numberOfElementsToProduce); DelayQueueProducer producer = new DelayQueueProducer( queue, numberOfElementsToProduce, delayOfEachProduceMessageMilliseconds); // when executor.submit(producer); executor.submit(consumer); // then executor.awaitTermination(5, TimeUnit.SECONDS); executor.shutdown(); assertEquals(consumer.numberOfConsumedElements.get(),numberOfElementsToProduce); } } 자바 언어로 딜레이큐를 작성해서 테스트 하고있었는데요. 이런 에러가 발생했습니다.사이트는 https://www.baeldung.com/java-delay-queue에서 따라해봤는데 저런 실행결과가 나오질않네요. 제가 놓치고 있는게 무엇일까요?

lloydkwon · Accepted Answer

DelayQueueConsumer 와 DelayQueueProducer 생성자를 제대로 만들지 않았나 보네요..아래 코드 참고하세요.. ^^ public DelayQueueConsumer(BlockingQueue queue, int numberOfElementsToTake) { this.queue = queue; this.numberOfElementsToTake = numberOfElementsToTake; } public DelayQueueProducer(BlockingQueue queue, Integer numberOfElementsToProduce, Integer delayOfEachProducedMessageMilliseconds) { this.queue = queue; this.numberOfElementsToProduce = numberOfElementsToProduce; this.delayOfEachProducedMessageMilliseconds = delayOfEachProducedMessageMilliseconds; }

안드로촙 · Answer

감사합니다. 수정해보겠습니다.

딜레이큐(delay queue) 테스트중 이런 에러가 발생했습니다.

2개의 답변

#queue 목록