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

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

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • 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().

    Description

      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.

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: