Searched refs:task (Results 151 - 175 of 210) sorted by relevance

123456789

/openjdk7/jdk/test/java/nio/file/attribute/UserDefinedFileAttributeView/
H A DBasic.java52 static void tryCatch(Class<? extends Throwable> ex, Task task) { argument
55 task.run();
67 static void expectNullPointerException(Task task) { argument
68 tryCatch(NullPointerException.class, task);
/openjdk7/langtools/test/tools/javac/api/6437999/
H A DT6437999.java67 task = tool.getTask(null, fm, null, null, null, files);
/openjdk7/jdk/src/share/classes/sun/awt/shell/
H A DShellFolder.java494 * Invokes the {@code task} which doesn't throw checked exceptions
498 public static <T> T invoke(Callable<T> task) { argument
500 return invoke(task, RuntimeException.class);
507 * Invokes the {@code task} which throws checked exceptions from its {@code call} method.
511 public static <T, E extends Throwable> T invoke(Callable<T> task, Class<E> exceptionClass) argument
514 return invoker.invoke(task);
542 * Invokes a callable task.
544 * @param task a task to invoke
545 * @throws Exception {@code InterruptedException} or an exception that was thrown from the {@code task}
548 invoke(Callable<T> task) argument
[all...]
/openjdk7/langtools/src/share/classes/com/sun/tools/javac/sym/
H A DCreateSymbols.java164 JavacTaskImpl task = (JavacTaskImpl)
167 com.sun.tools.javac.main.JavaCompiler.instance(task.getContext());
168 ClassReader reader = ClassReader.instance(task.getContext());
169 ClassWriter writer = ClassWriter.instance(task.getContext());
170 Symtab syms = Symtab.instance(task.getContext());
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DThreadPoolExecutor.java44 * An {@link ExecutorService} that executes each submitted task using
50 * asynchronous tasks, due to reduced per-task invocation overhead,
78 * When a new task is submitted in method {@link #execute}, and fewer
149 * this would exceed maximumPoolSize, in which case, the task will be
159 * without otherwise holding them. Here, an attempt to queue a task
174 * each task is completely independent of others, so tasks cannot
216 * that invokes {@code execute} itself runs the task. This provides a
220 * <li> In {@link ThreadPoolExecutor.DiscardPolicy}, a task that
224 * executor is not shut down, the task at the head of the work queue
239 * before and after execution of each task
1752 remove(Runnable task) argument
[all...]
H A DForkJoinWorkerThread.java47 * and termination methods surrounding the main task processing loop.
106 * task processing is in FIFO, not LIFO order; simply by using a
119 * task, it first tries a form of linear helping: Each worker
120 * records (in field currentSteal) the most recent task it stole
122 * the task it is currently actively joining. Method joinTask uses
124 * a task from and execute it) that could hasten completion of the
125 * actively joined task. In essence, the joiner executes a task
126 * that would be on its own local deque had the to-be-joined task
132 * upon steals, rather than use per-task bookkeepin
[all...]
/openjdk7/jdk/src/windows/classes/sun/nio/ch/
H A DWindowsAsynchronousSocketChannelImpl.java169 public void onCancel(PendingFuture<?,?> task) { argument
170 if (task.getContext() instanceof ConnectTask)
172 if (task.getContext() instanceof ReadTask)
174 if (task.getContext() instanceof WriteTask)
179 * Implements the task to initiate a connection and the handler to
353 // setup task
356 ConnectTask task = new ConnectTask<A>(isa, result);
357 result.setContext(task);
361 task.run();
363 Invoker.invokeOnThreadInThreadPool(this, task);
[all...]
/openjdk7/langtools/test/tools/javac/6400872/
H A DT6400872.java77 JavaCompiler.CompilationTask task =
79 if (!task.call())
/openjdk7/jdk/test/javax/swing/regtesthelpers/
H A DUtil.java209 * Invokes the <code>task</code> on the EDT thread.
211 * @return result of the <code>task</code>
213 public static <T> T invokeOnEDT(final Callable<T> task) throws Exception { argument
221 result.add(task.call());
/openjdk7/langtools/test/tools/javac/
H A DT6956638.java102 JavaCompiler.CompilationTask task = compiler.getTask(compilerOutputStream, fileManager, null, compileOptions, null, sourceFileObjects);
103 JavacTask javacTask = (JavacTask) task;
/openjdk7/langtools/test/tools/javac/api/
H A DT6412669.java73 JavacTask task = tool.getTask(sw, fm, null, Arrays.asList(opts), null, files);
74 boolean ok = task.call();
/openjdk7/langtools/test/tools/javac/classreader/
H A DT7031108.java116 CompilationTask task = comp.getTask(null, fm, dl, opts, null, Arrays.asList(files));
117 boolean ok = task.call();
/openjdk7/langtools/test/tools/javac/api/lib/
H A DToolTester.java41 public JavaCompiler.CompilationTask task = null; field in class:ToolTester
/openjdk7/hotspot/src/share/vm/ci/
H A DciEnv.cpp94 ciEnv::ciEnv(CompileTask* task, int system_dictionary_modification_counter) { argument
114 assert(task == NULL || thread->task() == task, "sanity");
115 _task = task;
930 // Print out the compile task that failed
1051 // (Put nm into the task handle *before* publishing to the Java heap.)
1052 if (task() != NULL) task()->set_code(nm);
1110 if (task()
[all...]
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DInvoker.java34 * Defines static methods to invoke a completion handler or arbitrary task.
235 * Invokes the given task on the thread pool associated with the given
236 * channel. If the current thread is in the thread pool then the task is
240 Runnable task)
252 task.run();
254 targetGroup.executeOnPooledThread(task);
239 invokeOnThreadInThreadPool(Groupable channel, Runnable task) argument
/openjdk7/langtools/test/tools/javac/processing/errors/
H A DTestSuppression.java118 JavacTask task = tool.getTask(pw, fm, dl, args, null, files);
119 task.setProcessors(Arrays.asList(new AnnoProc()));
120 boolean ok = task.call();
/openjdk7/jdk/test/sun/reflect/CallerSensitive/
H A DCallerSensitiveFinder.java178 FutureTask<String> task = new FutureTask<String>(new Callable<String>() {
183 tasks.add(task);
184 return task;
/openjdk7/hotspot/src/share/vm/gc_implementation/parallelScavenge/
H A DgcTaskManager.hpp76 const uint _affinity; // Which worker should run task.
80 virtual char* name() { return (char *)"task"; }
168 // Enqueue one task.
169 void enqueue(GCTask* task);
172 // Dequeue one task.
174 // Dequeue one task, preferring one with affinity.
211 GCTask* remove(GCTask* task); // Remove from the middle.
248 void enqueue(GCTask* task) { argument
250 unsynchronized_queue()->enqueue(task);
298 // GC threads wait in get_task() for work (i.e., a task) t
[all...]
H A DpsScavenge.cpp183 virtual void execute(ProcessTask& task);
184 virtual void execute(EnqueueTask& task);
187 void PSRefProcTaskExecutor::execute(ProcessTask& task) argument
192 q->enqueue(new PSRefProcTaskProxy(task, i));
196 if (task.marks_oops_alive() && manager->active_workers() > 1) {
205 void PSRefProcTaskExecutor::execute(EnqueueTask& task) argument
210 q->enqueue(new PSRefEnqueueTaskProxy(task, i));
/openjdk7/jdk/src/windows/classes/sun/awt/shell/
H A DWin32ShellFolderManager2.java497 public synchronized Thread newThread(final Runnable task) { argument
502 task.run();
529 public <T> T invoke(Callable<T> task) throws Exception { argument
532 // thread, we don't need to delegate the task
533 return task.call();
538 future = submit(task);
/openjdk7/hotspot/src/share/vm/runtime/
H A Dfprofiler.cpp40 #include "runtime/task.hpp"
65 FlatProfilerTask* FlatProfiler::task = NULL; member in class:FlatProfiler
794 void task();
861 if (cthread->task() != NULL) {
863 // of the compiler task we should suspend the CompilerThread first.
928 void FlatProfilerTask::task() { function in class:FlatProfilerTask
1222 if (task == NULL) {
1223 task = new FlatProfilerTask(WatcherThread::delay_interval);
1224 task->enroll();
1243 if (!task) {
[all...]
/openjdk7/jdk/test/sun/security/ssl/sun/net/www/httpstest/
H A DHttpServer.java358 Runnable task;
359 while ((task = sslEng.getDelegatedTask()) != null) {
360 task.run();
401 Runnable task;
402 while ((task = sslEng.getDelegatedTask()) != null) {
403 task.run();
/openjdk7/jdk/src/share/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/
H A DScanManager.java483 // You can call schedule only when the current task is
487 // switch reserved for background task: goes from SCHEDULED to
491 // switch reserved for background task: goes from RUNNING to
496 // switch reserved for background task:
592 LOG.fine("scheduling new task: state="+state);
597 LOG.fine("new task scheduled: state="+state);
604 // Schedule a SessionTask. The session task may reschedule
605 // a new identical task when it eventually ends.
607 // starting at the end of the task that finishes, rather than
608 // at its beginning. Therefore if a repeated task take
611 scheduleSession(SessionTask task, long delay) argument
[all...]
/openjdk7/hotspot/src/share/vm/gc_implementation/shared/
H A DmarkSweep.cpp130 ObjArrayTask task = _objarray_stack.pop(); local
131 objArrayKlass* const k = (objArrayKlass*)task.obj()->blueprint();
132 k->oop_follow_contents(task.obj(), task.index());
/openjdk7/hotspot/test/runtime/6925573/
H A DSortMethodsTest.java88 CompilationTask task = comp.getTask(null, mfm, diags, null, null, Arrays.asList(file));
90 if (task.call()) {

Completed in 70 milliseconds

123456789