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

Run local operations from a DistributedExecutor in parallel

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Duplicate
    • Icon: Critical Critical
    • 5.2.0.Final
    • 5.1.0.FINAL
    • Clustered Executor
    • None

      Looking into

      org.infinispan.distexec.DefaultExecutorService.invokeLocally(DistributedRunnableFuture<T>)

      It seems that the operations are performed in the same thread as the invoker; if we happen to send multiple operations to the local node, these are performed in sequence, and in sequence with the remote operations. We should use an Executor for the local tasks.

      Edit by Manik:
      After discussing with Sanne and Vladimir, I am reopening this issue as it isn't really a duplicate of ISPN-1274. This is more about being able to take a task and run the task, locally, using multiple threads (not just on a separate thread). Essentially a lot closer to Fork/Join, but with the ability to run this on multiple nodes. The degenerate case would possibly look a lot like the JDK's F/J, on a single node.

              vblagoje Vladimir Blagojevic (Inactive)
              sgrinove Sanne Grinovero (Inactive)
              Archiver:
              rhn-support-adongare Amol Dongare

                Created:
                Updated:
                Resolved:
                Archived: