/openjdk10/jdk/src/java.base/share/classes/java/util/concurrent/ |
H A D | Executor.java | 42 * 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 D | CompletionStage.java | 84 * 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 D | ExecutorCompletionService.java | 39 * 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 D | ThreadLocalContainerResolver.java | 28 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 D | AsyncProvider.java | 32 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 D | ExecutorWrapper.java | 32 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 D | HttpClient.java | 36 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 D | HttpClientBuilderImpl.java | 31 import java.util.concurrent.Executor; 44 Executor executor; 76 public HttpClientBuilderImpl executor(Executor s) {
|
H A D | ExchangeImpl.java | 30 import java.util.concurrent.Executor; 131 Executor executor); 136 abstract CompletableFuture<Response> getResponseAsync(Executor executor);
|
H A D | DefaultPublisher.java | 30 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 D | AsExecutor.java | 36 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 D | Engine.java | 28 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 D | test_collectorPolicy.cpp | 36 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 D | NotificationBroadcasterSupport.java | 32 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 D | Interrupt.java | 42 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 D | HttpsServerImpl.java | 69 public void setExecutor (Executor executor) { 73 public Executor getExecutor () {
|
H A D | HttpServerImpl.java | 61 public void setExecutor (Executor executor) { 65 public Executor getExecutor () {
|
/openjdk10/jdk/src/jdk.httpserver/share/classes/com/sun/net/httpserver/ |
H A D | HttpServer.java | 51 * {@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 D | StressAddJcmdBase.java | 30 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 D | WSHttpHandler.java | 37 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 D | HttpEndpoint.java | 35 import java.util.concurrent.Executor; 55 private final Executor executor; 57 public HttpEndpoint(Executor executor, HttpAdapter adapter) {
|
H A D | PortableHttpHandler.java | 37 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 D | MinimalFuture.java | 31 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 D | AutoShutdown.java | 42 import java.util.concurrent.Executor; 55 final Executor[] executors = { 76 for (Executor executor : executors)
|
/openjdk10/jdk/test/java/util/concurrent/tck/ |
H A D | ExecutorCompletionService9Test.java | 43 import java.util.concurrent.Executor; 58 void solveAll(Executor e, 71 void solveAny(Executor e,
|