[ https://issues.jboss.org/browse/ISPN-2496?page=com.atlassian.jira.plugin.... ] Anna Manukyan commented on ISPN-2496: ------------------------------------- I think I've found why this issue happens. I tried to insert just a simple NotifyingFuture into PriorityBlockingQueue, and found out that the insertable future should be comparable. In my case it thrown ClassCastException. Then I took the line 61 of DistributedExecutionCompletionService into try-catch, and the following exception has been thrown: java.lang.ClassCastException: org.infinispan.distexec.DefaultExecutorService$DistributedTaskPart cannot be cast to java.lang.Comparable at java.util.concurrent.PriorityBlockingQueue.siftUpComparable(PriorityBlockingQueue.java:347) at java.util.concurrent.PriorityBlockingQueue.offer(PriorityBlockingQueue.java:475) at java.util.concurrent.PriorityBlockingQueue.add(PriorityBlockingQueue.java:449) at org.infinispan.distexec.DistributedExecutionCompletionService$QueueingListener.futureDone(DistributedExecutionCompletionService.java:62) at org.infinispan.distexec.DefaultExecutorService$DistributedTaskPart.notifyDone(DefaultExecutorService.java:949) at org.infinispan.remoting.rpc.RpcManagerImpl$1.call(RpcManagerImpl.java:297) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) at java.util.concurrent.FutureTask.run(FutureTask.java:166) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:722) And the hangout takes place, because the take() method waits till there is one completed task in a completion queue and as the exception is thrown, it just enters into never ending loop. -- 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

[ https://issues.jboss.org/browse/ISPN-2496?page=com.atlassian.jira.plugin.... ] Anna Manukyan commented on ISPN-2496: ------------------------------------- Yup, agree. -- 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

[ https://issues.jboss.org/browse/ISPN-2496?page=com.atlassian.jira.plugin.... ] Dan Berindei commented on ISPN-2496: ------------------------------------ Actually the user could use a PriorityBlockingQueue if he supplied a Comparator (e.g. one that extracts the user-supplied Callable from the DistributedTaskPart and sorts based on some attributes of that callable). It's ok for DefaultExecutorService to not work a particular BlockingQueue implementation, as long as it fails with a reasonably clear exception. -- 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

[ https://issues.jboss.org/browse/ISPN-2496?page=com.atlassian.jira.plugin.... ] Dan Berindei updated ISPN-2496: ------------------------------- Status: Resolved (was: Pull Request Sent) Resolution: Done I integrated the PriorityBlockingQueue warning. -- 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

[ https://issues.jboss.org/browse/ISPN-2496?page=com.atlassian.jira.plugin.... ] Tristan Tarrant updated ISPN-2496: ---------------------------------- Fix Version/s: 5.2.0.Beta5 (was: 5.2.0.CR1) -- 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