/openjdk10/jdk/src/java.base/share/classes/java/util/stream/ |
H A D | AbstractTask.java | 34 * Each task is associated with a {@link Spliterator} that describes the portion 35 * of the input associated with the subtree rooted at this task. 41 * <p>This class is based on {@link CountedCompleter}, a form of fork-join task 42 * where each task has a semaphore-like count of uncompleted children, and the 43 * task is implicitly completed and notified when its last child completes. 46 * current task's result. 48 * <p>Splitting and setting up the child task links is done by {@code compute()} 53 * <p>For example, a task that performs a reduce would override {@code doLeaf()} 104 * rooted at this task 147 * @param parent this node's parent task [all...] |
H A D | ForEachOps.java | 287 ForEachTask<S, T> task = this; 291 task.helper.copyInto(taskSink, rightSplit); 294 ForEachTask<S, T> leftTask = new ForEachTask<>(task, leftSplit); 295 task.addToPendingCount(1); 300 taskToFork = task; 301 task = leftTask; 310 task.spliterator = null; 311 task.propagateCompletion(); 322 * Our goal is to ensure that the elements associated with a task are 325 * a task doe 403 doCompute(ForEachOrderedTask<S, T> task) argument [all...] |
/openjdk10/langtools/test/tools/javac/modules/ |
H A D | QueryBeforeEnter.java | 70 com.sun.source.util.JavacTask task = 72 TypeElement jlString = task.getElements().getTypeElement("java.lang.String"); 130 com.sun.source.util.JavacTask task = 139 assertNotNull(task.getElements().getTypeElement("java.lang.String")); 140 assertNotNull(task.getElements().getTypeElement("javax.tools.ToolProvider")); 141 assertNull(task.getElements().getTypeElement("m1x.M1")); 142 assertNull(task.getElements().getTypeElement("m2x.M2")); 143 assertNotNull(task.getElements().getTypeElement("cp.CP")); 144 assertNotNull(task.getElements().getTypeElement("test.Test1")); 145 assertNotNull(task 363 init(com.sun.source.util.JavacTask task, String... args) argument [all...] |
H A D | BrokenModulesTest.java | 67 JavacTaskImpl task = (JavacTaskImpl) compiler.getTask(null, null, null, opts, jlObjectList, null); 69 task.enter(); 71 task.getElements().getModuleElement("java.base"); 84 JavacTaskImpl task = (JavacTaskImpl) compiler.getTask(null, null, null, opts, jlObjectList, null); 86 task.enter(); 88 task.getElements().getModuleElement("java.base"); 103 JavacTaskImpl task = (JavacTaskImpl) compiler.getTask(null, null, null, opts, jlObjectList, null); 105 task.analyze(); 107 task.getElements().getModuleElement("java.base");
|
H A D | ModuleInfoTreeAccess.java | 71 JavacTask task = (JavacTask) compiler.getTask(null, fm, null, null, null, files); 73 task.analyze(); 74 JavacTrees trees = JavacTrees.instance(task); 75 ModuleElement mdle = (ModuleElement) task.getElements().getModuleElement("m1x"); 96 JavacTask task = (JavacTask) compiler.getTask(null, fm, null, null, null, files); 98 task.analyze(); 99 JavacTrees trees = JavacTrees.instance(task); 100 ModuleElement mdle = (ModuleElement) task.getElements().getModuleElement("m1x");
|
/openjdk10/hotspot/src/share/vm/gc/g1/ |
H A D | g1ConcurrentMarkObjArrayProcessor.hpp | 39 // Reference to the task for doing the actual work. 50 G1CMObjArrayProcessor(G1CMTask* task) : _task(task) { argument
|
/openjdk10/jdk/test/sun/rmi/rmic/newrmic/equivalence/ |
H A D | ComputeServerImpl.java | 29 * Class accepts a task and runs it in its own space. 41 * Accepts task and runs it 43 public Object compute(Task task) { argument 44 return task.run();
|
/openjdk10/langtools/test/tools/javac/api/6423003/ |
H A D | T6423003.java | 42 task = tool.getTask(null, fm, null, Arrays.asList("-Xlint:all"), null, null); 44 task.call();
|
/openjdk10/jdk/src/java.base/share/classes/sun/nio/ch/ |
H A D | AsynchronousChannelGroupImpl.java | 63 // task queue for when using a fixed thread pool. In that case, thread 107 private Runnable bindToGroup(final Runnable task) { argument 112 task.run(); 117 private void startInternalThread(final Runnable task) { argument 123 ThreadPool.defaultThreadFactory().newThread(task).start(); 129 protected final void startThreads(Runnable task) { argument 132 startInternalThread(task); 137 task = bindToGroup(task); 140 pool.executor().execute(task); 156 threadExit(Runnable task, boolean replaceMe) argument 177 executeOnHandlerTask(Runnable task) argument 184 executeOnPooledThread(Runnable task) argument 192 offerTask(Runnable task) argument 200 schedule(Runnable task, long timeout, TimeUnit unit) argument 319 execute(Runnable task) argument [all...] |
/openjdk10/jdk/test/java/lang/String/ |
H A D | StringContentEqualsBug.java | 92 for (Task task : tasks) { 93 if (task.exception != null) { 94 throw task.exception; 101 for (Task task : tasks) { 102 task.sb = null; 103 task.join();
|
/openjdk10/langtools/test/jdk/javadoc/tool/ |
H A D | IgnoreSourceErrors.java | 69 JavadocTask task = new JavadocTask(tb, Task.Mode.CMDLINE); 70 task.options(testSrc.toString()); 71 Task.Result result = task.run(Expect.FAIL); 80 JavadocTask task = new JavadocTask(tb, Task.Mode.CMDLINE); 81 task.options("--ignore-source-errors", testSrc.toString()); 82 Task.Result result = task.run(Expect.SUCCESS);
|
/openjdk10/jdk/test/java/util/concurrent/FutureTask/ |
H A D | Throw.java | 54 MyFutureTask(Callable<Void> task) { super(task); } argument 58 MyFutureTask checkTask(final MyFutureTask task) { argument 59 check(! task.isCancelled()); 60 check(! task.isDone()); 61 return task; 90 final MyFutureTask task = taskFor(c, null); 91 check(task.cancel(false)); 93 new F(){void f() throws Throwable { task.get(); }}); 97 final MyFutureTask task [all...] |
/openjdk10/jdk/test/java/util/concurrent/ScheduledThreadPoolExecutor/ |
H A D | DecorateTask.java | 54 final RunnableScheduledFuture<V> task) { 58 task.run(); 61 return task.isPeriodic(); 64 return task.cancel(mayInterruptIfRunning); 67 return task.isCancelled(); 70 return task.isDone(); 74 return task.get(); 78 return task.get(timeout, unit); 81 return task.getDelay(unit); 84 return task [all...] |
/openjdk10/hotspot/src/share/vm/compiler/ |
H A D | compileBroker.cpp | 183 void log_compile(JavaThread* thread, CompileTask* task) { argument 187 task->print(&sstr, NULL, true, false); 197 void log_failure(JavaThread* thread, CompileTask* task, const char* reason, const char* retry_message) { argument 199 lm.print("%4d COMPILE SKIPPED: %s", task->compile_id(), reason); 236 CompileTaskWrapper::CompileTaskWrapper(CompileTask* task) { argument 238 thread->set_task(task); 240 if (task->is_blocking() && CompileBroker::compiler(task->comp_level())->is_jvmci()) { 241 task->set_jvmci_compiler_thread(thread); 245 if (log != NULL) task 250 CompileTask* task = thread->task(); local 292 add(CompileTask* task) argument 392 CompileTask* task; local 434 remove(CompileTask* task) argument 454 remove_and_mark_stale(CompileTask* task) argument 467 CompileTask* task = _first; local 501 CompileTask* task = _first; local 912 CompileTask* task = NULL; local 1374 wait_for_jvmci_completion(JVMCICompiler* jvmci, CompileTask* task, JavaThread* thread) argument 1416 wait_for_completion(CompileTask* task) argument 1606 CompileTask* task = queue->get(); local 1764 post_compile(CompilerThread* thread, CompileTask* task, EventCompilation& event, bool success, ciEnv* ci_env) argument 1802 invoke_compiler_on_method(CompileTask* task) argument 2154 collect_statistics(CompilerThread* thread, elapsedTimer time, CompileTask* task) argument [all...] |
/openjdk10/langtools/src/jdk.jdeps/share/classes/com/sun/tools/jdeps/ |
H A D | JdepsTask.java | 138 abstract void process(JdepsTask task, String opt, String arg) throws BadArgs; argument 179 void process(JdepsTask task, String opt, String arg) { 180 task.options.help = true; 184 void process(JdepsTask task, String opt, String arg) throws BadArgs { 185 if (task.command != null) { 186 throw new BadArgs("err.command.set", task.command, opt); 188 task.command = task.genDotFile(Paths.get(arg)); 192 void process(JdepsTask task, String opt, String arg) { 193 task [all...] |
/openjdk10/langtools/test/tools/javac/api/ |
H A D | TestResolveError.java | 50 * of calling task.parseType with a name whose resolution depended on the setting 52 * This test has the same call, task.parseType("List<String>", clazz), but checks 68 task = (JavacTaskImpl)tool.getTask(pw, fm, null, null, null, compilationUnits); 69 elements = task.getElements(); 70 types = task.getTypes(); 73 toplevels = ElementFilter.typesIn(task.enter(task.parse())); 92 DeclaredType type = (DeclaredType)task.parseType("List<String>", clazz); 99 JavacTaskImpl task; field in class:TestResolveError
|
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/ |
H A D | CooperativeHandler.java | 34 * A synchronization aid that assists a number of parties in running a task 37 * To run the task, a party invokes `handle`. To permanently prevent the task 42 * The task can be either synchronous or asynchronous. 44 * If the task is synchronous, it is represented with `Runnable`. 45 * The handler invokes `Runnable.run` to run the task. 47 * If the task is asynchronous, it is represented with `Consumer<Runnable>`. 48 * The handler invokes `Consumer.accept(end)` to begin the task. The task 51 * The next run of the task wil 109 CooperativeHandler(Runnable task) argument 201 asyncOf(Runnable task) argument [all...] |
/openjdk10/hotspot/src/jdk.hotspot.agent/share/classes/sun/jvm/hotspot/debugger/bsd/ |
H A D | BsdDebuggerLocal.java | 70 private long task; // macosx task handle field in class:BsdDebuggerLocal 130 WorkerThreadTask task; field in class:BsdDebuggerLocal.BsdDebuggerLocalWorkerThread 141 if (task != null) { 144 task.doit(debugger); 148 task = null; 159 public WorkerThreadTask execute(WorkerThreadTask task) throws DebuggerException { argument 161 this.task = task; 163 while (this.task ! [all...] |
/openjdk10/jdk/src/jdk.internal.jvmstat/share/classes/sun/jvmstat/perfdata/monitor/protocol/local/ |
H A D | MonitoredHostProvider.java | 45 private NotifierTask task; field in class:MonitoredHostProvider 102 if (task == null) { 103 task = new NotifierTask(); 105 timer.schedule(task, interval, interval); 116 if (listeners.isEmpty() && (task != null)) { 117 task.cancel(); 118 task = null; 135 if (task != null) { 136 task.cancel(); 137 NotifierTask oldTask = task; [all...] |
/openjdk10/langtools/test/tools/javac/api/6412656/ |
H A D | T6412656.java | 47 task = tool.getTask(null, fm, null, null, 49 task.setProcessors(Collections.singleton(new MyProc(this))); 50 task.call();
|
/openjdk10/hotspot/src/jdk.hotspot.agent/share/classes/sun/jvm/hotspot/debugger/linux/ |
H A D | LinuxDebuggerLocal.java | 124 WorkerThreadTask task; field in class:LinuxDebuggerLocal.LinuxDebuggerLocalWorkerThread 135 if (task != null) { 138 task.doit(debugger); 142 task = null; 153 public WorkerThreadTask execute(WorkerThreadTask task) throws DebuggerException { argument 155 this.task = task; 157 while (this.task != null) { 165 return task; 276 AttachTask task [all...] |
/openjdk10/jdk/src/java.rmi/share/classes/sun/rmi/transport/ |
H A D | DGCAckHandler.java | 82 private Future<?> task = null; field in class:DGCAckHandler 118 if (objList != null && task == null) { 119 task = scheduler.schedule(new Runnable() { 134 if (task != null) { 135 task.cancel(false); 136 task = null;
|
/openjdk10/langtools/test/tools/lib/toolbox/ |
H A D | Task.java | 40 * Returns the name of the task. 41 * @return the name of the task 46 * Executes the task as currently configured. 47 * @return a Result object containing the results of running the task 48 * @throws TaskError if the outcome of the task was not as expected 67 * An enum to indicate the mode a task should use it is when executed. 71 * The task should use the interface used by the command 72 * line launcher for the task. 77 * The task should use a publicly defined API for the task 121 final Task task; field in class:Task.Result 125 Result(ToolBox toolBox, Task task, int exitCode, Map<OutputKind, String> outputMap) argument [all...] |
/openjdk10/langtools/test/tools/javac/T8171325/ |
H A D | NPEClearingLocalClassNameIndexesTest.java | 18 f(g((String) null, task -> g(new NoSuch() {}))); 19 f(g((String) null, task -> g(new NoSuch<int>() {})));
|
/openjdk10/langtools/test/tools/javac/api/6468404/ |
H A D | T6468404.java | 63 task = tool.getTask( 66 task.setProcessors(Collections.singleton(new P())); 67 if (!task.call()) 71 task = tool.getTask( 74 task.setProcessors(Collections.singleton(new P())); 75 if (!task.call()) 78 task = tool.getTask( 82 if (!task.call()) 86 task = tool.getTask( 89 task [all...] |