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

[Anna Manukyan (JIRA)]

Anna Manukyan created ISPN-2496:
-----------------------------------

             Summary: 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/test/java/org/infinispan/distexec/DistributedExecutionCompletionTest.java (testBasicInvocationWithBlockingQueue()).

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira