Searched refs:tasks (Results 1 - 25 of 44) sorted by relevance

12

/openjdk10/jdk/src/java.desktop/share/classes/javax/swing/text/
H A DLayoutQueue.java31 * 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 DStringContentEqualsBug.java82 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 DShutdownHooks.java17 * 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 DInvoke.java74 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 DBug8066652.java38 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 DAbstractExecutorService.java147 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 DExecutorService.java44 * 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 DFJExceptionTableLeak.java76 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 DPooledExecution.java54 // 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 DTestConstructorFinder.java54 List<Task> tasks = new ArrayList<>();
56 tasks.add(new Task<Constructor>(constructors) {
67 for (Task task : tasks) {
H A DTestMethodFinder.java54 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 DBlockingTaskExecutor.java58 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 Dmx_graal_9.py204 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 DStressTest.java77 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 DGetObjectName.java47 int tasks = 10000;
49 submitTasks(executor, tasks);
/openjdk10/jdk/test/java/util/concurrent/tck/
H A DScheduledExecutorSubclassTest.java235 * 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 DScheduledExecutorTest.java179 * 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 DForkJoinTask8Test.java401 * 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 DThreadPoolExecutorSubclassTest.java348 * 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 DThreadPoolExecutorTest.java206 * 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 DLangtoolsIdeaAntLogger.java126 * 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 DJdkIdeaAntLogger.java130 * 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 DTestJavacTask_Multiple.java94 List<CompilationTask> tasks = new ArrayList<CompilationTask>();
101 tasks.add(t);
104 for (CompilationTask t: tasks)
/openjdk10/jdk/test/jdk/internal/reflect/CallerSensitive/
H A DCheckCSMs.java205 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 DCallerSensitiveFinder.java191 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");

Completed in 267 milliseconds

12