/openjdk10/jdk/src/java.desktop/share/classes/javax/swing/text/ |
H A D | LayoutQueue.java | 31 * A queue of text layout tasks. 41 private Vector<Runnable> tasks; field in class:LayoutQueue 48 tasks = new Vector<Runnable>(); 98 tasks.addElement(task); 107 while (tasks.size() == 0) { 114 Runnable work = tasks.firstElement(); 115 tasks.removeElementAt(0);
|
/openjdk10/jdk/test/java/lang/String/ |
H A D | StringContentEqualsBug.java | 82 Task[] tasks = new Task[3]; 83 (tasks[0] = new Tester(sb)).start(); 84 for (int i = 1; i < tasks.length; i++) { 85 (tasks[i] = new Disturber(sb)).start(); 92 for (Task task : tasks) { 101 for (Task task : tasks) {
|
/openjdk10/jdk/src/jdk.internal.le/share/classes/jdk/internal/jline/internal/ |
H A D | ShutdownHooks.java | 17 * Manages the JLine shutdown-hook thread and tasks to execute on shutdown. 28 private static final List<Task> tasks = new ArrayList<Task>(); field in class:ShutdownHooks 54 tasks.add(task); 60 Log.debug("Running all shutdown-hook tasks"); 62 // Iterate through copy of tasks list 63 for (Task task : tasks.toArray(new Task[tasks.size()])) { 73 tasks.clear(); 97 tasks.remove(task); 99 // If there are no more tasks, the [all...] |
/openjdk10/jdk/test/java/util/concurrent/ExecutorService/ |
H A D | Invoke.java | 74 List<Inc> tasks = Arrays.asList(new Inc(), new Inc(), new Inc()); 75 List<Future<Long>> futures = fixed.invokeAll(tasks); 76 check(futures.size() == tasks.size()); 77 check(count.get() == tasks.size()); 81 check(gauss == ((tasks.size()+1)*tasks.size())/2); 85 check(single.invokeAny(tasks) == save + 1);
|
/openjdk10/jdk/test/java/util/TimeZone/ |
H A D | Bug8066652.java | 38 List<Callable<TimeZone>> tasks = new ArrayList<>(); 40 tasks.add(calTimeZone); 43 List<Future<TimeZone>> results = executor.invokeAll(tasks);
|
/openjdk10/jdk/src/java.base/share/classes/java/util/concurrent/ |
H A D | AbstractExecutorService.java | 147 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, argument 150 if (tasks == null) 152 int ntasks = tasks.size(); 160 // parallelism, check to see if previously submitted tasks are 170 Iterator<? extends Callable<T>> it = tasks.iterator(); 217 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) argument 220 return doInvokeAny(tasks, false, 0); 227 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, argument 230 return doInvokeAny(tasks, true, unit.toNanos(timeout)); 233 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) argument 259 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
H A D | ExecutorService.java | 44 * one or more asynchronous tasks. 47 * it to reject new tasks. Two different methods are provided for 49 * method will allow previously submitted tasks to execute before 51 * tasks from starting and attempts to stop currently executing tasks. 52 * Upon termination, an executor has no tasks actively executing, no 53 * tasks awaiting execution, and no new tasks can be submitted. An 62 * tasks and then waiting for at least one, or all, to 106 * first by calling {@code shutdown} to reject incoming tasks, an 288 invokeAll(Collection<? extends Callable<T>> tasks) argument 319 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 342 invokeAny(Collection<? extends Callable<T>> tasks) argument 368 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
/openjdk10/jdk/test/java/util/concurrent/forkjoin/ |
H A D | FJExceptionTableLeak.java | 76 final ArrayList<FailingTask> tasks = new ArrayList<>(); 78 // Keep submitting failing tasks until most of the exception 84 tasks.add(task); // retain strong refs to all tasks, for now 86 for (FailingTask task : tasks) { 96 FailingTask lastTask = tasks.get(0); 99 tasks.clear();
|
/openjdk10/langtools/test/tools/sjavac/ |
H A D | PooledExecution.java | 54 // Number of tasks that has not yet started 64 // Keep track of the number of finished tasks so we can make sure all 65 // tasks finishes gracefully upon shutdown. 66 Thread[] tasks = new Thread[NUM_REQUESTS]; 70 tasks[i] = new Thread() { 76 tasks[i].start(); 79 // Wait for all tasks to start (but not necessarily run to completion) 82 // Shutdown before all tasks are completed 86 // Wait for all tasks to complete 87 for (Thread t : tasks) [all...] |
/openjdk10/jdk/test/java/beans/XMLDecoder/8028054/ |
H A D | TestConstructorFinder.java | 54 List<Task> tasks = new ArrayList<>(); 56 tasks.add(new Task<Constructor>(constructors) { 67 for (Task task : tasks) {
|
H A D | TestMethodFinder.java | 54 List<Task> tasks = new ArrayList<>(); 56 tasks.add(new Task<Method>(methods) { 67 for (Task task : tasks) {
|
/openjdk10/jdk/test/java/util/concurrent/FutureTask/ |
H A D | BlockingTaskExecutor.java | 58 final Collection<Callable<Object>> tasks = new ArrayList<>(); 59 tasks.add(new BlockingTask(notifiee1)); 60 tasks.add(new BlockingTask(notifiee2)); 61 tasks.add(new NonBlockingTask()); 63 // start a thread to invoke the tasks 65 try { executor.invokeAll(tasks); } 70 // Wait until tasks begin execution 74 // Now try to shutdown the executor service while tasks 75 // are blocked. This should cause the tasks to be
|
/openjdk10/hotspot/src/jdk.internal.vm.compiler/.mx.graal/ |
H A D | mx_graal_9.py | 204 def run(self, suites, tasks, extraVMarguments=None): 206 with Task(self.name + ': hosted-release ' + suite, tasks) as t: 215 def run(self, tasks, extraVMarguments=None): 217 with Task(self.name, tasks) as t: 230 def run(self, tasks, extraVMarguments=None): 231 with Task(self.name + ': hosted-product ', tasks) as t: 234 def compiler_gate_runner(suites, unit_test_runs, bootstrap_tests, tasks, extraVMarguments=None): 239 r.run(suites, tasks, extraVMarguments) 244 r.run(tasks, extraVMarguments) 248 with Task('CTW:hosted', tasks) a [all...] |
/openjdk10/jdk/test/java/util/ResourceBundle/Control/ |
H A D | StressTest.java | 77 Thread[] tasks = new Thread[locales.length * threadsFactor]; 78 counters = new AtomicIntegerArray(tasks.length); 80 for (int i = 0; i < tasks.length; i++) { 81 tasks[i] = new Thread(new Worker(i)); 83 for (int i = 0; i < tasks.length; i++) { 84 tasks[i].start(); 88 intervalForCounterCheck = Math.max(tasks.length / nProcessors, 1); 100 for (int i = 0; i < tasks.length; i++) { 101 tasks[i].join();
|
/openjdk10/jdk/test/java/lang/management/ManagementFactory/ |
H A D | GetObjectName.java | 47 int tasks = 10000; 49 submitTasks(executor, tasks);
|
/openjdk10/jdk/test/java/util/concurrent/tck/ |
H A D | ScheduledExecutorSubclassTest.java | 235 * scheduleAtFixedRate executes series of tasks at given rate. 264 * scheduleWithFixedDelay executes series of tasks with given period. 310 * Submitting null tasks throws NullPointerException 320 * Submitted tasks are rejected when shutdown 365 done.countDown(); // release blocking tasks 396 * when tasks complete 481 * getTaskCount increases, but doesn't overestimate, when tasks 614 * getQueue returns the work queue, which contains queued tasks 621 ScheduledFuture[] tasks = new ScheduledFuture[5]; 622 for (int i = 0; i < tasks [all...] |
H A D | ScheduledExecutorTest.java | 179 * scheduleAtFixedRate executes series of tasks at given rate. 208 * scheduleWithFixedDelay executes series of tasks with given period. 254 * Submitting null tasks throws NullPointerException 264 * Submitted tasks are rejected when shutdown 309 done.countDown(); // release blocking tasks 340 * when tasks complete 425 * getTaskCount increases, but doesn't overestimate, when tasks 572 * getQueue returns the work queue, which contains queued tasks 579 ScheduledFuture[] tasks = new ScheduledFuture[5]; 580 for (int i = 0; i < tasks [all...] |
H A D | ForkJoinTask8Test.java | 401 * completed tasks; getRawResult returns null. 422 * completed tasks 543 * helpQuiesce returns when tasks are complete. 797 * invokeAll(tasks) with 1 argument invokes task 827 AsyncFib[] tasks = { 831 invokeAll(tasks[0], tasks[1]); 832 for (AsyncFib task : tasks) assertTrue(task.isDone()); 833 for (AsyncFib task : tasks) task.checkCompletedNormally(); 839 * invokeAll(tasks) wit [all...] |
H A D | ThreadPoolExecutorSubclassTest.java | 348 * when tasks complete 570 * getTaskCount increases, but doesn't overestimate, when tasks submitted 679 * getQueue returns the work queue, which contains queued tasks 690 FutureTask[] tasks = new FutureTask[5]; 691 for (int i = 0; i < tasks.length; i++) { 699 tasks[i] = new FutureTask(task); 700 p.execute(tasks[i]); 704 assertFalse(q.contains(tasks[0])); 705 assertTrue(q.contains(tasks[tasks [all...] |
H A D | ThreadPoolExecutorTest.java | 206 * when tasks complete 441 * getTaskCount increases, but doesn't overestimate, when tasks submitted 582 * getQueue returns the work queue, which contains queued tasks 593 FutureTask[] tasks = new FutureTask[5]; 594 for (int i = 0; i < tasks.length; i++) { 602 tasks[i] = new FutureTask(task); 603 p.execute(tasks[i]); 607 assertFalse(q.contains(tasks[0])); 608 assertTrue(q.contains(tasks[tasks [all...] |
/openjdk10/langtools/make/intellij/src/idea/ |
H A D | LangtoolsIdeaAntLogger.java | 126 * This enum is used to represent the list of tasks we need to keep track of during logging. 141 /** synthetic task catching any other tasks not in this list */ 255 /** stack of pending tasks */ 256 Stack<Task> tasks = new Stack<>(); field in class:LangtoolsIdeaAntLogger 267 tasks.push(Task.ROOT); 314 tasks.push(task); 322 if (tasks.peek() == Task.ROOT) { 333 tasks.pop(); 342 if (!tasks.isEmpty()) { 343 Task task = tasks [all...] |
/openjdk10/make/idea/template/src/idea/ |
H A D | JdkIdeaAntLogger.java | 130 * This enum is used to represent the list of tasks we need to keep track of during logging. 145 /** synthetic task catching any other tasks not in this list */ 266 /** stack of pending tasks */ 267 Stack<Task> tasks = new Stack<>(); field in class:JdkIdeaAntLogger 277 tasks.push(Task.ROOT); 325 tasks.push(task); 333 if (tasks.peek() == Task.ROOT) { 344 tasks.pop(); 353 if (!tasks.isEmpty()) { 354 Task task = tasks [all...] |
/openjdk10/langtools/test/tools/javac/api/ |
H A D | TestJavacTask_Multiple.java | 94 List<CompilationTask> tasks = new ArrayList<CompilationTask>(); 101 tasks.add(t); 104 for (CompilationTask t: tasks)
|
/openjdk10/jdk/test/jdk/internal/reflect/CallerSensitive/ |
H A D | CheckCSMs.java | 205 private final List<FutureTask<Void>> tasks = new ArrayList<FutureTask<Void>>(); field in class:CheckCSMs 213 tasks.add(task); 218 for (FutureTask<Void> t : tasks) { 221 if (tasks.isEmpty()) { 224 System.out.println("Parsed " + tasks.size() + " classfiles");
|
H A D | CallerSensitiveFinder.java | 191 private final List<FutureTask<Void>> tasks = new ArrayList<FutureTask<Void>>(); field in class:CallerSensitiveFinder 199 tasks.add(task); 204 for (FutureTask<Void> t : tasks) { 207 if (tasks.isEmpty()) { 210 System.out.println("Parsed " + tasks.size() + " classfiles");
|