Lines Matching refs:tasks

73         final TestTask[] tasks = new TestTask[TASK_COUNT];  in concurrentProcessingTestIteration()  local
77 tasks[i] = new TestTask(Integer.valueOf(i + 1), result::addAndGet); in concurrentProcessingTestIteration()
82 threads[i] = factory.createRunner(tasks); in concurrentProcessingTestIteration()
107 protected final TestTask[] tasks; field in Main.TaskRunner
109 TaskRunner(TestTask[] tasks) { in TaskRunner() argument
110 this.tasks = tasks; in TaskRunner()
117 TestTask t = (TestTask) QA.get(tasks, i); in run()
149 TaskRunnerWithCompareAndExchange(TestTask[] tasks) { in TaskRunnerWithCompareAndExchange() argument
150 super(tasks); in TaskRunnerWithCompareAndExchange()
155 return (t == QA.compareAndExchange(tasks, i, t, null)); in grabTask()
160 TaskRunnerWithCompareAndSet(TestTask[] tasks) { in TaskRunnerWithCompareAndSet() argument
161 super(tasks); in TaskRunnerWithCompareAndSet()
166 return QA.compareAndSet(tasks, i, t, null); in grabTask()
171 TaskRunnerWithWeakCompareAndSet(TestTask[] tasks) { in TaskRunnerWithWeakCompareAndSet() argument
172 super(tasks); in TaskRunnerWithWeakCompareAndSet()
177 return QA.weakCompareAndSet(tasks, i, t, null); in grabTask()
183 Thread createRunner(TestTask[] tasks); in createRunner() argument
188 public Thread createRunner(TestTask[] tasks) { in createRunner() argument
189 return new TaskRunnerWithCompareAndExchange(tasks); in createRunner()
195 public Thread createRunner(TestTask[] tasks) { in createRunner() argument
196 return new TaskRunnerWithCompareAndSet(tasks); in createRunner()
202 public Thread createRunner(TestTask[] tasks) { in createRunner() argument
203 return new TaskRunnerWithWeakCompareAndSet(tasks); in createRunner()