]
Tristan Tarrant updated ISPN-2496:
----------------------------------
Fix Version/s: 5.2.0.Beta5
(was: 5.2.0.CR1)
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
Fix For: 5.2.0.Beta5
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()).
--
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: