Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-1129

method o.i.distexec.DefaultExecutorService.invokeAny(Collection tasks) never returns

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 5.0.0.CR4
    • 5.0.0.CR3
    • Clustered Executor
    • None
    • Hide

      org.infinispan.distexec.DistributedExecutorTest

      public void testInvokeAny() throws Exception

      { DistributedExecutorService des = new DefaultExecutorService(c1); Integer r = des.invokeAny(Arrays.<Callable<Integer>>asList( new SimpleCallable(),new SimpleCallable(),new SimpleCallable()), 100, TimeUnit.MILLISECONDS); assert r == 1; }

      as result I have timeout exception, avoiding the time boundary leads to an infinite invokeAny().

      Show
      org.infinispan.distexec.DistributedExecutorTest public void testInvokeAny() throws Exception { DistributedExecutorService des = new DefaultExecutorService(c1); Integer r = des.invokeAny(Arrays.<Callable<Integer>>asList( new SimpleCallable(),new SimpleCallable(),new SimpleCallable()), 100, TimeUnit.MILLISECONDS); assert r == 1; } as result I have timeout exception, avoiding the time boundary leads to an infinite invokeAny().

      DefaultExecutorService.invokeAny() seems not working ever just because DistributedExecutionCompletionService seems not working too, because it never attach it's listener to tasks. I made a test, but didn't find an easy approach to fix it.

              vblagoje Vladimir Blagojevic (Inactive)
              mkhludnev Mikhail Khludnev (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: