Java Doc for ExecutorService.java in  » 6.0-JDK-Core » Collections-Jar-Zip-Logging-regex » java » util » concurrent » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Home
Java Source Code / Java Documentation
1.6.0 JDK Core
2.6.0 JDK Modules
3.6.0 JDK Modules com.sun
4.6.0 JDK Modules com.sun.java
5.6.0 JDK Modules sun
6.6.0 JDK Platform
7.Ajax
8.Apache Harmony Java SE
9.Aspect oriented
10.Authentication Authorization
11.Blogger System
12.Build
13.Byte Code
14.Cache
15.Chart
16.Chat
17.Code Analyzer
18.Collaboration
19.Content Management System
20.Database Client
21.Database DBMS
22.Database JDBC Connection Pool
23.Database ORM
24.Development
25.EJB Server
26.ERP CRM Financial
27.ESB
28.Forum
29.Game
30.GIS
31.Graphic 3D
32.Graphic Library
33.Groupware
34.HTML Parser
35.IDE
36.IDE Eclipse
37.IDE Netbeans
38.Installer
39.Internationalization Localization
40.Inversion of Control
41.Issue Tracking
42.J2EE
43.J2ME
44.JBoss
45.JMS
46.JMX
47.Library
48.Mail Clients
49.Music
50.Net
51.Parser
52.PDF
53.Portal
54.Profiler
55.Project Management
56.Report
57.RSS RDF
58.Rule Engine
59.Science
60.Scripting
61.Search Engine
62.Security
63.Sevlet Container
64.Source Control
65.Swing Library
66.Template Engine
67.Test Coverage
68.Testing
69.UML
70.Web Crawler
71.Web Framework
72.Web Mail
73.Web Server
74.Web Services
75.Web Services apache cxf 2.2.6
76.Web Services AXIS2
77.Wiki Engine
78.Workflow Engines
79.XML
80.XML UI
Java Source Code / Java Documentation » 6.0 JDK Core » Collections Jar Zip Logging regex » java.util.concurrent 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.util.concurrent.ExecutorService

All known Subclasses:   java.util.concurrent.AbstractExecutorService,
ExecutorService
public interface ExecutorService extends Executor(Code)
An Executor that provides methods to manage termination and methods that can produce a Future for tracking progress of one or more asynchronous tasks.

An ExecutorService can be shut down, which will cause it to reject new tasks. Two different methods are provided for shutting down an ExecutorService. The ExecutorService.shutdown method will allow previously submitted tasks to execute before terminating, while the ExecutorService.shutdownNow method prevents waiting tasks from starting and attempts to stop currently executing tasks. Upon termination, an executor has no tasks actively executing, no tasks awaiting execution, and no new tasks can be submitted. An unused ExecutorService should be shut down to allow reclamation of its resources.

Method submit extends base method Executor.execute by creating and returning a Future that can be used to cancel execution and/or wait for completion. Methods invokeAny and invokeAll perform the most commonly useful forms of bulk execution, executing a collection of tasks and then waiting for at least one, or all, to complete. (Class ExecutorCompletionService can be used to write customized variants of these methods.)

The Executors class provides factory methods for the executor services provided in this package.

Usage Examples

Here is a sketch of a network service in which threads in a thread pool service incoming requests. It uses the preconfigured Executors.newFixedThreadPool factory method:
 class NetworkService implements Runnable {
 private final ServerSocket serverSocket;
 private final ExecutorService pool;
 public NetworkService(int port, int poolSize)
 throws IOException {
 serverSocket = new ServerSocket(port);
 pool = Executors.newFixedThreadPool(poolSize);
 }
 public void run() { // run the service
 try {
 for (;;) {
 pool.execute(new Handler(serverSocket.accept()));
 }
 } catch (IOException ex) {
 pool.shutdown();
 }
 }
 }
 class Handler implements Runnable {
 private final Socket socket;
 Handler(Socket socket) { this.socket = socket; }
 public void run() {
 // read and service request on socket
 }
 }
 
The following method shuts down an ExecutorService in two phases, first by calling shutdown to reject incoming tasks, and then calling shutdownNow, if necessary, to cancel any lingering tasks:
 void shutdownAndAwaitTermination(ExecutorService pool) {
 pool.shutdown(); // Disable new tasks from being submitted
 try {
 // Wait a while for existing tasks to terminate
 if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
 pool.shutdownNow(); // Cancel currently executing tasks
 // Wait a while for tasks to respond to being cancelled
 if (!pool.awaitTermination(60, TimeUnit.SECONDS))
 System.err.println("Pool did not terminate");
 }
 } catch (InterruptedException ie) {
 // (Re-)Cancel if current thread also interrupted
 pool.shutdownNow();
 // Preserve interrupt status
 Thread.currentThread().interrupt();
 }
 }
 

Memory consistency effects: Actions in a thread prior to the submission of a Runnable or Callable task to an ExecutorService happen-before any actions taken by that task, which in turn happen-before the result is retrieved via Future.get() .
since:
   1.5
author:
   Doug Lea





Method Summary
 booleanawaitTermination(long timeout, TimeUnit unit)
     Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
 List<Future<T>>invokeAll(Collection<? extends Callable<T>> tasks)
     Executes the given tasks, returning a list of Futures holding their status and results when all complete.
 List<Future<T>>invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
     Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first. Future.isDone is true for each element of the returned list. Upon return, tasks that have not completed are cancelled. Note that a completed task could have terminated either normally or by throwing an exception. The results of this method are undefined if the given collection is modified while this operation is in progress.
Parameters:
  tasks - the collection of tasks
Parameters:
  timeout - the maximum time to wait
Parameters:
  unit - the time unit of the timeout argument a list of Futures representing the tasks, in the samesequential order as produced by the iterator for thegiven task list.
 TinvokeAny(Collection<? extends Callable<T>> tasks)
     Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do.
 TinvokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
     Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do before the given timeout elapses.
 booleanisShutdown()
     Returns true if this executor has been shut down.
 booleanisTerminated()
     Returns true if all tasks have completed following shut down.
 voidshutdown()
     Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
 List<Runnable>shutdownNow()
     Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks.

 Future<T>submit(Callable<T> task)
     Submits a value-returning task for execution and returns a Future representing the pending results of the task.
 Future<T>submit(Runnable task, T result)
     Submits a Runnable task for execution and returns a Future representing that task.
 Futuresubmit(Runnable task)
     Submits a Runnable task for execution and returns a Future representing that task.



Method Detail
awaitTermination
boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException(Code)
Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
Parameters:
  timeout - the maximum time to wait
Parameters:
  unit - the time unit of the timeout argument true if this executor terminated andfalse if the timeout elapsed before termination
throws:
  InterruptedException - if interrupted while waiting



invokeAll
List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException(Code)
Executes the given tasks, returning a list of Futures holding their status and results when all complete. Future.isDone is true for each element of the returned list. Note that a completed task could have terminated either normally or by throwing an exception. The results of this method are undefined if the given collection is modified while this operation is in progress.
Parameters:
  tasks - the collection of tasks A list of Futures representing the tasks, in the samesequential order as produced by the iterator for thegiven task list, each of which has completed.
throws:
  InterruptedException - if interrupted while waiting, inwhich case unfinished tasks are cancelled.
throws:
  NullPointerException - if tasks or any of its elements are null
throws:
  RejectedExecutionException - if any task cannot bescheduled for execution



invokeAll
List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException(Code)
Executes the given tasks, returning a list of Futures holding their status and results when all complete or the timeout expires, whichever happens first. Future.isDone is true for each element of the returned list. Upon return, tasks that have not completed are cancelled. Note that a completed task could have terminated either normally or by throwing an exception. The results of this method are undefined if the given collection is modified while this operation is in progress.
Parameters:
  tasks - the collection of tasks
Parameters:
  timeout - the maximum time to wait
Parameters:
  unit - the time unit of the timeout argument a list of Futures representing the tasks, in the samesequential order as produced by the iterator for thegiven task list. If the operation did not time out,each task will have completed. If it did time out, someof these tasks will not have completed.
throws:
  InterruptedException - if interrupted while waiting, inwhich case unfinished tasks are cancelled
throws:
  NullPointerException - if tasks, any of its elements, orunit are null
throws:
  RejectedExecutionException - if any task cannot be scheduledfor execution



invokeAny
T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException(Code)
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do. Upon normal or exceptional return, tasks that have not completed are cancelled. The results of this method are undefined if the given collection is modified while this operation is in progress.
Parameters:
  tasks - the collection of tasks the result returned by one of the tasks
throws:
  InterruptedException - if interrupted while waiting
throws:
  NullPointerException - if tasks or any of its elementsare null
throws:
  IllegalArgumentException - if tasks is empty
throws:
  ExecutionException - if no task successfully completes
throws:
  RejectedExecutionException - if tasks cannot be scheduledfor execution



invokeAny
T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException(Code)
Executes the given tasks, returning the result of one that has completed successfully (i.e., without throwing an exception), if any do before the given timeout elapses. Upon normal or exceptional return, tasks that have not completed are cancelled. The results of this method are undefined if the given collection is modified while this operation is in progress.
Parameters:
  tasks - the collection of tasks
Parameters:
  timeout - the maximum time to wait
Parameters:
  unit - the time unit of the timeout argument the result returned by one of the tasks.
throws:
  InterruptedException - if interrupted while waiting
throws:
  NullPointerException - if tasks, any of its elements, orunit are null
throws:
  TimeoutException - if the given timeout elapses beforeany task successfully completes
throws:
  ExecutionException - if no task successfully completes
throws:
  RejectedExecutionException - if tasks cannot be scheduledfor execution



isShutdown
boolean isShutdown()(Code)
Returns true if this executor has been shut down. true if this executor has been shut down



isTerminated
boolean isTerminated()(Code)
Returns true if all tasks have completed following shut down. Note that isTerminated is never true unless either shutdown or shutdownNow was called first. true if all tasks have completed following shut down



shutdown
void shutdown()(Code)
Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.
throws:
  SecurityException - if a security manager exists andshutting down this ExecutorService may manipulatethreads that the caller is not permitted to modifybecause it does not hold java.lang.RuntimePermission("modifyThread"),or the security manager's checkAccess methoddenies access.



shutdownNow
List<Runnable> shutdownNow()(Code)
Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread.interrupt , so any task that fails to respond to interrupts may never terminate. list of tasks that never commenced execution
throws:
  SecurityException - if a security manager exists andshutting down this ExecutorService may manipulatethreads that the caller is not permitted to modifybecause it does not hold java.lang.RuntimePermission("modifyThread"),or the security manager's checkAccess methoddenies access.




submit
Future<T> submit(Callable<T> task)(Code)
Submits a value-returning task for execution and returns a Future representing the pending results of the task. The Future's get method will return the task's result upon successful completion.

If you would like to immediately block waiting for a task, you can use constructions of the form result = exec.submit(aCallable).get();

Note: The Executors class includes a set of methods that can convert some other common closure-like objects, for example, java.security.PrivilegedAction to Callable form so they can be submitted.
Parameters:
  task - the task to submit a Future representing pending completion of the task
throws:
  RejectedExecutionException - if the task cannot bescheduled for execution
throws:
  NullPointerException - if the task is null




submit
Future<T> submit(Runnable task, T result)(Code)
Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return the given result upon successful completion.
Parameters:
  task - the task to submit
Parameters:
  result - the result to return a Future representing pending completion of the task
throws:
  RejectedExecutionException - if the task cannot bescheduled for execution
throws:
  NullPointerException - if the task is null



submit
Future submit(Runnable task)(Code)
Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return null upon successful completion.
Parameters:
  task - the task to submit a Future representing pending completion of the task
throws:
  RejectedExecutionException - if the task cannot bescheduled for execution
throws:
  NullPointerException - if the task is null



www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.