딜레이큐(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 = 1; int delayOfEachProduceMessageMilliseconds = 10_000; 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(),0); } } 안드로이드 스튜디오로 딜레이큐를 테스트 하는 코딩을 하고 있었습니다.그런데 이러한 오류가 뜨면서 막혔습니다. 어떻게 하면될까요? 제가 인수를 설정을 안해서 오류가 난것일까요? 사이트는 이 사이트를 참고해서 만들어봤습니다.https://www.baeldung.com/java-delay-queue

안드로촙 · Answer

alt&#43;enter로 퀵픽스 해보니 해결이 된거같네요?이게 해결이 된게 맞겠죠? 생성자를 생성해준다고 퀵픽스해주던데 하니깐 됬습니다!

딜레이큐(delay queue)를 만들던중 이런 오류가 발생했습니다.

1개의 답변

#queue 목록