Executors Core Java

Constructing a new thread is somewhat expensive because it involves interaction with the operating system. If your program creates a large number of short-lived threads, then it should instead use a thread pool. A thread pool contains a number of idle threads that are ready to run. You give a Runnable to the pool, and one of the threads calls the runmethod. When the run method exits, the thread doesn’t die but stays around to serve the next request.

Another reason to use a thread pool is to throttle the number of concurrent threads. Creating a huge number of threads can greatly degrade performance and even crash the virtual machine. If you have an algorithm that creates lots of threads, then you should use a “fixed” thread pool that bounds the total number of concurrent threads. The Executors class has a number of static factory methods for constructing thread pools; see Table below for a summary.

Thread Pools

Let us look at the first three methods in Table below. We discuss the remaining methodsin the section “Scheduled Execution”. The newCachedThreadPool method constructs a thread pool that executes each task immediately, using an existing idle thread when available and creating a new thread otherwise. The newFixedThreadPool method constructs a thread pool with a fixed size. If more tasks are submitted than there are idle threads, then the unserved tasks are placed on a queue. They are run when other tasks have completed. The newSingleThreadExecutor is a degenerate pool of size 1: A single thread executes the submitted tasks, one after another. These three methods return an object of the ThreadPoolExecutor class that implements the ExecutorService interface.

You can submit a Runnable or Callable to an ExecutorService with one of the following methods:

The pool will run the submitted task at its earliest convenience. When you call submit, you get back a Future object that you can use to query the state of the task. The first submit method returns an odd-looking Future<?>. You can use such an object to call isDone, cancel, or isCancelled. But the get method simply returns null upon completion.

The second version of submit also submits a Runnable, and the get method of the Future returns the given result object upon completion. The third version submits a Callable, and the returned Future gets the result of the computation when it is ready.

When you are done with a thread pool, call shutdown. This method initiates the shutdown sequence for the pool. An executor that is shut down accepts no new tasks. When all tasks are finished, the threads in the pool die. Alternatively, you can call shutdownNow. The pool then cancels all tasks that have not yet begun and attempts to interrupt the running threads.

Executors Factory Methods

Executors Factory Methods

Here, in summary, is what you do to use a connection pool:

  1. Call the static newCachedThreadPool or newFixedThreadPool method of the Executors class.
  2. Call submit to submit Runnable or Callable objects.
  3. If you want to be able to cancel a task or if you submit Callable objects, hang on to the returned Future objects.
  4. Call shutdown when you no longer want to submit any tasks.

For example, the preceding example program produced a large number of short-lived threads, one per directory.

For informational purposes, this program prints out the largest pool size during execution. This information is not available through the ExecutorService interface. For that reason, we had to cast the pool object to the ThreadPoolExecutor class.

java.util.concurrent.Executors

  • ExecutorService newCachedThreadPool()
    returns a cached thread pool that creates threads as needed and terminates threads that have been idle for 60 seconds.
  • ExecutorService newFixedThreadPool(int threads)
    returns a thread pool that uses the given number of threads to execute tasks.
  • ExecutorService newSingleThreadExecutor()
    returns an executor that executes tasks sequentially in a single thread.

java.util.concurrent.ExecutorService

  • Future<T> submit(Callable<T> task)
  • Future<T> submit(Runnable task, T result)
  • Future<?> submit(Runnable task)
    submits the given task for execution.
  • void shutdown()
    shuts down the service, completing the already submitted tasks but not accepting new submissions.

java.util.concurrent.ThreadPoolExecutor

  • int getLargestPoolSize()
    returns the largest size of the thread pool during the life of this executor.

Scheduled Execution

The ScheduledExecutorService interface has methods for scheduled or repeated execution of tasks. It is a generalization of java.util.Timer that allows for thread pooling. The newScheduledThreadPooland newSingleThreadScheduledExecutor methods of the Executors class return objects that implement the ScheduledExecutorService interface.

You can schedule a Runnable or Callable to run once, after an initial delay. You can also schedule a Runnable to run periodically. See the API notes for details.

java.util.concurrent.Executors

  • ScheduledExecutorService newScheduledThreadPool(int threads)
    returns a thread pool that uses the given number of threads to schedule tasks.
  • ScheduledExecutorService newSingleThreadScheduledExecutor()
    returns an executor that schedules tasks in a single thread.

java.util.concurrent.ScheduledExecutorService

  • ScheduledFuture<V> schedule(Callable<V> task, long time, TimeUnit unit)
  • ScheduledFuture<?> schedule(Runnable task, long time, TimeUnit unit)
    schedules the given task after the given time has elapsed.
  • ScheduledFuture<?> scheduleAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit) schedules the given task to run periodially, every period units, after the initialdelay has elapsed.
  • ScheduledFuture<?> scheduleWithFixedDelay(Runnable task, long initialDelay, long delay, TimeUnit unit) schedules the given task to run periodially, with delay units between completion ofone invocation and the start of the next, after the initial delay has elapsed.

Controlling Groups of Tasks

You have seen how to use an executor service as a thread pool to increase the efficiency of task execution. Sometimes, an executor is used for a more tactical reason,simply to control a group of related tasks. For example, you can cancel all tasks in anexecutor with the shutdownNow method.

The invokeAny method submits all objects in a collection of Callable objects and returns the result of a completed task. You don’t know which task that is—presumably, it was the one that finished most quickly. You would use this method for a search problem in which you are willing to accept any solution. For example, suppose that you need to factor a large integer—a computation that is required for breaking the RSA cipher. You could submit a number of tasks, each of which attempts a factorization by using numbers in a different range. As soon as one of these tasks has an answer, your computation can stop.

The invokeAll method submits all objects in a collection of Callable objects and returns a list of Future objects that represent the solutions to all tasks. You can process the results of the computation when they are available, like this:

A disadvantage with this approach is that you may wait needlessly if the first task happens to take a long time. It would make more sense to obtain the results in the order in which they are available. This can be arranged with the Executor Completion Service.

Start with an executor, obtained in the usual way. Then construct an ExecutorCompletion- Service. Submit tasks to the completion service. The service manages a blocking queue of Future objects, containing the results of the submitted tasks as they become available.

Thus, a more efficient organization for the preceding computation is the following:

java.util.concurrent.ExecutorService

  • T invokeAny(Collection<Callable<T>> tasks)
  • T invokeAny(Collection<Callable<T>> tasks, long timeout, TimeUnit unit)
    executes the given tasks and returns the result of one of them. The second method throws a TimeoutException if a timeout occurs.
  • List<Future<T>> invokeAll(Collection<Callable<T>> tasks)
  • List<Future<T>> invokeAll(Collection<Callable<T>> tasks, long timeout, TimeUnit unit)
  • executes the given tasks and returns the results of all of them. The second method throws a TimeoutException if a timeout occurs.

  • ExecutorCompletionService(Executor e)
    constructs an executor completion service that collects the results of the given executor.
  • Future<T> submit(Callable<T> task)
  • Future<T> submit(Runnable task, T result)
    submits a task to the underlying executor.
  • Future<T> take()
    removes the next completed result, blocking if no completed results are available.
  • Future<T> poll()
  • Future<T> poll(long time, TimeUnit unit)

removes the next completed result or null if no completed results are available. The second method waits for the given time.


Face Book Twitter Google Plus Instagram Youtube Linkedin Myspace Pinterest Soundcloud Wikipedia

All rights reserved © 2018 Wisdom IT Services India Pvt. Ltd DMCA.com Protection Status

Core Java Topics