Searched refs:task (Results 26 - 50 of 393) sorted by relevance

1234567891011>>

/openjdk10/jdk/src/java.base/share/classes/java/util/stream/
H A DAbstractTask.java34 * 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 DForEachOps.java287 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 DQueryBeforeEnter.java70 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 DBrokenModulesTest.java67 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 DModuleInfoTreeAccess.java71 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 Dg1ConcurrentMarkObjArrayProcessor.hpp39 // 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 DComputeServerImpl.java29 * 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 DT6423003.java42 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 DAsynchronousChannelGroupImpl.java63 // 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 DStringContentEqualsBug.java92 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 DIgnoreSourceErrors.java69 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 DThrow.java54 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 DDecorateTask.java54 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 DcompileBroker.cpp183 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 DJdepsTask.java138 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 DTestResolveError.java50 * 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 DCooperativeHandler.java34 * 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 DBsdDebuggerLocal.java70 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 DMonitoredHostProvider.java45 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 DT6412656.java47 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 DLinuxDebuggerLocal.java124 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 DDGCAckHandler.java82 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 DTask.java40 * 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 DNPEClearingLocalClassNameIndexesTest.java18 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 DT6468404.java63 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...]

Completed in 160 milliseconds

1234567891011>>