Searched refs:Executor (Results 1 - 25 of 41) sorted by relevance

12

/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DExecutor.java42 * use, scheduling, etc. An <tt>Executor</tt> is normally used
48 * Executor executor = <em>anExecutor</em>;
54 * However, the <tt>Executor</tt> interface does not strictly
60 * class DirectExecutor implements Executor {
71 * class ThreadPerTaskExecutor implements Executor {
77 * Many <tt>Executor</tt> implementations impose some sort of
83 * class SerialExecutor implements Executor {
85 * final Executor executor;
88 * SerialExecutor(Executor executor) {
114 * The <tt>Executor</t
128 public interface Executor { interface
[all...]
H A DExecutorCompletionService.java39 * A {@link CompletionService} that uses a supplied {@link Executor}
56 * void solve(Executor e,
76 * void solve(Executor e,
108 private final Executor executor;
146 public ExecutorCompletionService(Executor executor) {
168 public ExecutorCompletionService(Executor executor,
H A DExecutorService.java43 * An {@link Executor} that provides methods to manage termination and
59 * Executor#execute} by creating and returning a {@link Future} that
141 public interface ExecutorService extends Executor {
/openjdk7/jdk/src/macosx/classes/com/apple/concurrent/
H A DLibDispatchConcurrentQueue.java28 import java.util.concurrent.Executor;
30 class LibDispatchConcurrentQueue extends LibDispatchQueue implements Executor {
H A DLibDispatchMainQueue.java28 import java.util.concurrent.Executor;
30 abstract class LibDispatchMainQueue extends LibDispatchQueue implements Executor {
H A DDispatch.java31 * Factory for {@link Executor}s and {@link ExecutorService}s backed by
76 * Creates an {@link Executor} that performs tasks asynchronously. The {@link Executor}
78 * returns the {@link Priority.NORMAL} {@link Executor}.
80 * @param priority - the priority of the returned {@link Executor}
81 * @return an asynchronous {@link Executor}
83 public Executor getAsyncExecutor(Priority priority) {
116 Executor nonBlockingMainQueue = null;
118 * Returns an {@link Executor} that performs the provided Runnables on the main queue of the process.
119 * Runnables submitted to this {@link Executor} wil
[all...]
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/
H A DEngine.java28 import java.util.concurrent.Executor;
37 * Owns an {@link Executor} to run them.
43 private volatile Executor threadPool;
46 public Engine(String id, Executor threadPool) {
55 public void setExecutor(Executor threadPool) {
/openjdk7/jdk/test/java/nio/channels/AsynchronousChannelGroup/
H A DAsExecutor.java62 Executor executor = (Executor)group;
73 Executor executor = (Executor)group;
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/server/
H A DAsyncProvider.java32 import java.util.concurrent.Executor;
63 * private static final {@link Executor} exec = ...;
/openjdk7/jdk/src/share/classes/javax/management/
H A DNotificationBroadcasterSupport.java31 import java.util.concurrent.Executor;
46 * Executor to the constructor.</p>
50 * if the method call of a filter or of {@code Executor.execute} or of
65 * {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
74 * the given {@link java.util.concurrent.Executor}. When {@link #sendNotification
80 * {@link Executor#execute executor.execute} is called with a command
83 * {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
90 public NotificationBroadcasterSupport(Executor executor) {
99 * NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
121 * and where each listener is invoked using the given {@link java.util.concurrent.Executor}
[all...]
/openjdk7/jdk/src/share/classes/com/sun/net/httpserver/
H A DHttpServer.java51 * {@link java.util.concurrent.Executor} object. If none is provided a default
154 * sets this server's {@link java.util.concurrent.Executor} object. An
155 * Executor must be established before {@link #start()} is called.
158 * called with a <code>null</code> Executor, then
161 * @param executor the Executor to set, or <code>null</code> for default
165 public abstract void setExecutor (Executor executor);
169 * returns this server's Executor object if one was specified with
170 * {@link #setExecutor(Executor)}, or <code>null</code> if none was
172 * @return the Executor established for this server or <code>null</code> if not set.
174 public abstract Executor getExecuto
[all...]
/openjdk7/jdk/src/share/classes/sun/net/httpserver/
H A DHttpServerImpl.java61 public void setExecutor (Executor executor) {
65 public Executor getExecutor () {
H A DHttpsServerImpl.java69 public void setExecutor (Executor executor) {
73 public Executor getExecutor () {
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DInterrupt.java38 static void checkInterrupted0(Iterable<Fun> fs, Executor ex) {
53 final Executor immediateExecutor = new Executor() {
58 final Executor delayedExecutor = new Executor() {
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/server/
H A DHttpEndpoint.java36 import java.util.concurrent.Executor;
54 private final Executor executor;
56 public HttpEndpoint(Executor executor, HttpAdapter adapter) {
H A DPortableHttpHandler.java37 import java.util.concurrent.Executor;
58 private final Executor executor;
60 public PortableHttpHandler(@NotNull HttpAdapter adapter, @Nullable Executor executor) {
73 // Use application's Executor to handle request. Application may
103 * executed in Executor.
H A DWSHttpHandler.java39 import java.util.concurrent.Executor;
61 private final Executor executor;
63 public WSHttpHandler(@NotNull HttpAdapter adapter, @Nullable Executor executor) {
76 // Use application's Executor to handle request. Application may
106 * executed in Executor.
/openjdk7/jdk/test/java/util/concurrent/Executors/
H A DAutoShutdown.java61 Executor e1 = newSingleThreadExecutor();
62 Executor e2 = newSingleThreadExecutor(defaultThreadFactory());
/openjdk7/jaxws/src/share/jaxws_classes/javax/xml/ws/
H A DEndpoint.java50 * <p>An <code>Executor</code> may be set on the endpoint in order
69 * @see java.util.concurrent.Executor
380 * @return The <code>java.util.concurrent.Executor</code> to be
383 * @see java.util.concurrent.Executor
385 public abstract java.util.concurrent.Executor getExecutor();
398 * @param executor The <code>java.util.concurrent.Executor</code>
405 * @see java.util.concurrent.Executor
407 public abstract void setExecutor(java.util.concurrent.Executor executor);
/openjdk7/jdk/test/javax/management/remote/mandatory/threads/
H A DExecutorTest.java27 * @summary Tests that thread creation can use a user-supplied Executor
45 "fetch-notifications Executor", which is a
46 java.util.concurrent.Executor that will be used each time the
57 notification sending does in fact work (with the default Executor).
58 Then it creates a connection with the property set to an Executor
64 to happen as an Executor.execute call, if Executor.execute has been
66 Executor is not being used correctly.
118 Executor countExecutor = (Executor)
[all...]
/openjdk7/jdk/src/share/classes/java/sql/
H A DConnection.java29 import java.util.concurrent.Executor;
1356 * closed and the <code>Executor</code> that was passed as a parameter to abort
1365 * @param executor The <code>Executor</code> implementation which will
1372 * @see Executor
1375 void abort(Executor executor) throws SQLException;
1442 * @param executor The <code>Executor</code> implementation which will
1464 * @see Executor
1467 void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException;
/openjdk7/jdk/src/solaris/classes/java/lang/
H A DUNIXProcess.java.bsd39 import java.util.concurrent.Executor;
120 private static final Executor processReaperExecutor =
121 doPrivileged(new PrivilegedAction<Executor>() {
122 public Executor run() {
H A DUNIXProcess.java.linux39 import java.util.concurrent.Executor;
120 private static final Executor processReaperExecutor =
121 doPrivileged(new PrivilegedAction<Executor>() {
122 public Executor run() {
/openjdk7/jaxws/src/share/jaxws_classes/javax/xml/ws/spi/
H A DServiceDelegate.java598 * @return The <code>java.util.concurrent.Executor</code> to be
601 * @see java.util.concurrent.Executor
603 public abstract java.util.concurrent.Executor getExecutor();
611 * @param executor The <code>java.util.concurrent.Executor</code>
618 * @see java.util.concurrent.Executor
620 public abstract void setExecutor(java.util.concurrent.Executor executor);
/openjdk7/jdk/test/sun/security/ssl/sanity/interop/
H A DJSSEServer.java54 Executor exec = Executors.newFixedThreadPool

Completed in 94 milliseconds

12