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

DistributedExecutorMassIndexer.executeInternal should use an existing pool

    Details

      Description

      DistributedExecutorMassIndexer.executeInternal creates 2 executors:

      1. new DefaultExecutorService(cache) implicitly creates a single-threaded executor to run tasks on the local node.
      2. compositeFuture.whenCompleteAsync(consumer, Executors.newSingleThreadExecutor()) explicitly creates a new single-threaded executor to run the consumer on.

      Neither of these executors are shut down, and rather than complicating the code to stop them properly it would be better to use an existing executor.

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                dan.berindei Dan Berindei
                Reporter:
                dan.berindei Dan Berindei
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: