[
https://issues.apache.org/jira/browse/IGNITE-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589454#comment-15589454
]
Nadeem Mohammad commented on IGNITE-4093:
-----------------------------------------
Infinispan's org.infinispan.distexec.DistributedExecutionCompletionService
internally uses LinkedBlockingQueue, however this implementation is broken, the
moment the node goes down (In which the queue resides), all the content of the
nodes would be gone... further this queue is not shared with all the other
nodes in the cluster..
So if at all a decision is made to us Blocking queue in Ignite, Then it has to
be a Distributed Blocking Queue, otherwise the implementation would be broken
again. hope it helps
> Provide implementation of java.util.concurrent.CompletionService
> ----------------------------------------------------------------
>
> Key: IGNITE-4093
> URL: https://issues.apache.org/jira/browse/IGNITE-4093
> Project: Ignite
> Issue Type: Improvement
> Components: general
> Affects Versions: 1.7
> Reporter: Valentin Kulichenko
>
> Ignite provides the implementation of `ExecutorService`, but not
> `CompletionService`. There is `ExecutorCompletionService` in JDK, but it's
> implementation is weird and looks like there is no way to use it in
> distributed environment.
> I suggest to create our own implementation of `CompletionService` that will
> execute closures in distributed fashion.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
