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

1234

/openjdk10/jdk/src/java.base/share/classes/java/util/concurrent/
H A DExecutor.java42 * use, scheduling, etc. An {@code Executor} is normally used
48 * Executor executor = anExecutor();
53 * However, the {@code Executor} interface does not strictly require
58 * class DirectExecutor implements Executor {
69 * class ThreadPerTaskExecutor implements Executor {
75 * Many {@code Executor} implementations impose some sort of
81 * class SerialExecutor implements Executor {
83 * final Executor executor;
86 * SerialExecutor(Executor executor) {
110 * The {@code Executor} implementation
124 public interface Executor { interface
[all...]
H A DCompletionStage.java84 * or custom (via a supplied {@link Executor}). The execution
87 * explicit Executor arguments may have arbitrary execution
191 * normally, is executed using the supplied Executor, with this
205 Executor executor);
238 * normally, is executed using the supplied Executor, with this
250 Executor executor);
280 * normally, executes the given action using the supplied Executor.
291 Executor executor);
352 Executor executor);
410 Executor executo
[all...]
H A DExecutorCompletionService.java39 * A {@link CompletionService} that uses a supplied {@link Executor}
56 * void solve(Executor e,
74 * void solve(Executor e,
104 private final Executor executor;
145 public ExecutorCompletionService(Executor executor) {
167 public ExecutorCompletionService(Executor executor,
/openjdk10/jaxws/src/java.xml.ws/share/classes/com/sun/xml/internal/ws/api/server/
H A DThreadLocalContainerResolver.java28 import java.util.concurrent.Executor;
82 * @param ex Executor to wrap
83 * @return an Executor that will set the container during executions of Runnables
85 public Executor wrapExecutor(final Container container, final Executor ex) {
89 return new Executor() {
H A DAsyncProvider.java32 import java.util.concurrent.Executor;
63 * private static final {@link Executor} exec = ...;
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/
H A DExecutorWrapper.java32 import java.util.concurrent.Executor;
36 * Wraps the supplied user Executor
44 final Executor userExecutor; // the undeerlying executor provided by user
45 final Executor executor; // the executur which wraps the user's one
49 public ExecutorWrapper(Executor userExecutor, AccessControlContext acc) {
71 * The default client uses InnocuousThreads in its Executor.
98 public Executor userExecutor() {
102 public Executor executor() {
H A DHttpClient.java36 import java.util.concurrent.Executor;
140 * @param executor the Executor
143 public abstract Builder executor(Executor executor);
277 * Returns the {@code Executor} set on this client. If an {@code
278 * Executor} was not set on the client's builder, then a default
279 * object is returned. The default {@code Executor} is created independently
282 * @return this client's Executor
284 public abstract Executor executor();
H A DHttpClientBuilderImpl.java31 import java.util.concurrent.Executor;
44 Executor executor;
76 public HttpClientBuilderImpl executor(Executor s) {
H A DExchangeImpl.java30 import java.util.concurrent.Executor;
131 Executor executor);
136 abstract CompletableFuture<Response> getResponseAsync(Executor executor);
H A DDefaultPublisher.java30 import java.util.concurrent.Executor;
46 private final Executor executor;
51 DefaultPublisher(Supplier<Optional<T>> supplier, Executor executor) {
/openjdk10/jdk/test/java/nio/channels/AsynchronousChannelGroup/
H A DAsExecutor.java36 import java.util.concurrent.Executor;
77 Executor executor = (Executor)group;
88 Executor executor = (Executor)group;
/openjdk10/jaxws/src/java.xml.ws/share/classes/com/sun/xml/internal/ws/api/pipe/
H A DEngine.java28 import java.util.concurrent.Executor;
39 * Owns an {@link Executor} to run them.
45 private volatile Executor threadPool;
51 Executor getExecutor() { return threadPool; }
53 public Engine(String id, Executor threadPool) {
57 public Engine(String id, Container container, Executor threadPool) {
71 public void setExecutor(Executor threadPool) {
84 private Executor wrap(Executor ex) {
/openjdk10/hotspot/test/native/gc/shared/
H A Dtest_collectorPolicy.cpp36 class Executor { class in class:TestGenCollectorPolicy
41 class UnaryExecutor : public Executor {
48 class BinaryExecutor : public Executor {
68 static void test(Executor* setter1, Executor* setter2, Executor* checker) {
91 static void test(Executor* setter, Executor* checker) {
114 class CheckScaledYoungInitial : public Executor {
181 class CheckOldInitial : public Executor {
[all...]
/openjdk10/jdk/src/java.management/share/classes/javax/management/
H A DNotificationBroadcasterSupport.java32 import java.util.concurrent.Executor;
47 * Executor to the constructor.</p>
51 * if the method call of a filter or of {@code Executor.execute} or of
66 * {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
75 * the given {@link java.util.concurrent.Executor}. When {@link #sendNotification
81 * {@link Executor#execute executor.execute} is called with a command
84 * {@link NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
91 public NotificationBroadcasterSupport(Executor executor) {
100 * NotificationBroadcasterSupport#NotificationBroadcasterSupport(Executor,
122 * and where each listener is invoked using the given {@link java.util.concurrent.Executor}
[all...]
/openjdk10/jdk/test/java/util/concurrent/BlockingQueue/
H A DInterrupt.java42 import java.util.concurrent.Executor;
49 static void checkInterrupted0(Iterable<Fun> fs, Executor ex) {
65 final Executor immediateExecutor = new Executor() {
70 final Executor delayedExecutor = new Executor() {
/openjdk10/jdk/src/jdk.httpserver/share/classes/sun/net/httpserver/
H A DHttpsServerImpl.java69 public void setExecutor (Executor executor) {
73 public Executor getExecutor () {
H A DHttpServerImpl.java61 public void setExecutor (Executor executor) {
65 public Executor getExecutor () {
/openjdk10/jdk/src/jdk.httpserver/share/classes/com/sun/net/httpserver/
H A DHttpServer.java51 * {@link java.util.concurrent.Executor} object. If none is provided a default
162 * sets this server's {@link java.util.concurrent.Executor} object. An
163 * Executor must be established before {@link #start()} is called.
166 * called with a <code>null</code> Executor, then
169 * @param executor the Executor to set, or <code>null</code> for default
173 public abstract void setExecutor (Executor executor);
177 * returns this server's Executor object if one was specified with
178 * {@link #setExecutor(Executor)}, or <code>null</code> if none was
180 * @return the Executor established for this server or <code>null</code> if not set.
182 public abstract Executor getExecuto
[all...]
/openjdk10/hotspot/test/compiler/compilercontrol/jcmd/
H A DStressAddJcmdBase.java30 import compiler.compilercontrol.share.scenario.Executor;
70 Executor executor = new TimeLimitedExecutor();
116 private class TimeLimitedExecutor extends Executor {
/openjdk10/jaxws/src/java.xml.ws/share/classes/com/sun/xml/internal/ws/transport/http/server/
H A DWSHttpHandler.java37 import java.util.concurrent.Executor;
61 private final Executor executor;
63 public WSHttpHandler(@NotNull HttpAdapter adapter, @Nullable Executor executor) {
78 // Use application's Executor to handle request. Application may
111 * executed in Executor.
H A DHttpEndpoint.java35 import java.util.concurrent.Executor;
55 private final Executor executor;
57 public HttpEndpoint(Executor executor, HttpAdapter adapter) {
H A DPortableHttpHandler.java37 import java.util.concurrent.Executor;
59 private final Executor executor;
61 public PortableHttpHandler(@NotNull HttpAdapter adapter, @Nullable Executor executor) {
77 // Use application's Executor to handle request. Application may
109 * executed in Executor.
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/common/
H A DMinimalFuture.java31 import java.util.concurrent.Executor;
76 public static <U> CompletableFuture<U> supply(ExceptionalSupplier<U> supplier, Executor executor) {
119 Executor executor) {
/openjdk10/jdk/test/java/util/concurrent/Executors/
H A DAutoShutdown.java42 import java.util.concurrent.Executor;
55 final Executor[] executors = {
76 for (Executor executor : executors)
/openjdk10/jdk/test/java/util/concurrent/tck/
H A DExecutorCompletionService9Test.java43 import java.util.concurrent.Executor;
58 void solveAll(Executor e,
71 void solveAny(Executor e,

Completed in 238 milliseconds

1234