/openjdk7/jdk/test/java/nio/file/attribute/UserDefinedFileAttributeView/ |
H A D | Basic.java | 52 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 D | T6437999.java | 67 task = tool.getTask(null, fm, null, null, null, files);
|
/openjdk7/jdk/src/share/classes/sun/awt/shell/ |
H A D | ShellFolder.java | 494 * 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 D | CreateSymbols.java | 164 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 D | ThreadPoolExecutor.java | 44 * 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 D | ForkJoinWorkerThread.java | 47 * 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 D | WindowsAsynchronousSocketChannelImpl.java | 169 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 D | T6400872.java | 77 JavaCompiler.CompilationTask task = 79 if (!task.call())
|
/openjdk7/jdk/test/javax/swing/regtesthelpers/ |
H A D | Util.java | 209 * 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 D | T6956638.java | 102 JavaCompiler.CompilationTask task = compiler.getTask(compilerOutputStream, fileManager, null, compileOptions, null, sourceFileObjects); 103 JavacTask javacTask = (JavacTask) task;
|
/openjdk7/langtools/test/tools/javac/api/ |
H A D | T6412669.java | 73 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 D | T7031108.java | 116 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 D | ToolTester.java | 41 public JavaCompiler.CompilationTask task = null; field in class:ToolTester
|
/openjdk7/hotspot/src/share/vm/ci/ |
H A D | ciEnv.cpp | 94 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 D | Invoker.java | 34 * 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 D | TestSuppression.java | 118 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 D | CallerSensitiveFinder.java | 178 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 D | gcTaskManager.hpp | 76 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 D | psScavenge.cpp | 183 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 D | Win32ShellFolderManager2.java | 497 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 D | fprofiler.cpp | 40 #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 D | HttpServer.java | 358 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 D | ScanManager.java | 483 // 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 D | markSweep.cpp | 130 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 D | SortMethodsTest.java | 88 CompilationTask task = comp.getTask(null, mfm, diags, null, null, Arrays.asList(file)); 90 if (task.call()) {
|