[infinispan-issues] [JBoss JIRA] (ISPN-2496) Test for DistributedExecutionCompletionService hangs, if instantiation is done using PriorityBlockingQueue

Test for DistributedExecutionCompletionService hangs, if instantiation is done using PriorityBlockingQueue ---------------------------------------------------------------------------------------------------------- Key: ISPN-2496 URL: https://issues.jboss.org/browse/ISPN-2496 Project: Infinispan Issue Type: Bug Components: Distributed Execution and Map/Reduce Reporter: Anna Manukyan Assignee: Vladimir Blagojevic Hi, while writing tests for DistributedExecutionCompletionService, the following issue arrised: I'm creating DistributedExecutionCompletionService with constructor: DistributedExecutionCompletionService(DistributedExecutorService executor, BlockingQueue<NotifyingFuture<V>> completionQueue) If I'm passing as a completionQueue instance of ArrayBlockingQueue, then everything works properly. But if as a completionQueue I'm passing instance of PriorityBlockingQueue, then the test hangs. It hangs on line 61 of DistributedExecutionCompletionService: completionQueue.add((NotifyingFuture<V>)future); You can find the test reproducing the issue here: https://github.com/andyuk1986/infinispan/blob/DIST_EXEC_TESTS/core/src/te... (testBasicInvocationWithBlockingQueue()).