Searched refs:runnables (Results 1 – 5 of 5) sorted by relevance
56 private RunnableExecutorPair runnables; field in ExecutionList93 runnables = new RunnableExecutorPair(runnable, executor, runnables); in add()125 list = runnables; in execute()126 runnables = null; // allow GC to free listeners even if this stays around for a while. in execute()
278 final Queue<OldExecutionList.RunnableExecutorPair> runnables = Lists.newLinkedList();287 synchronized (runnables) {289 runnables.add(new RunnableExecutorPair(runnable, executor));301 synchronized (runnables) {308 while (!runnables.isEmpty()) {309 runnables.poll().execute();338 private RunnableExecutorPair runnables;348 runnables = new RunnableExecutorPair(runnable, executor, runnables);362 list = runnables;363 runnables = null; // allow GC to free listeners even if this stays around for a while.
24 public static void concurrently(Runnable ... runnables) throws InterruptedException { in concurrently() argument26 for (Runnable r : runnables) { in concurrently()
62 List<IWorker<T>> runnables = m_factory.createWorkers(freeNodes); in runNodes() local63 for (IWorker<T> r : runnables) { in runNodes()
780 List<IWorker<ITestNGMethod>> runnables = createWorkers(freeNodes); in privateRun() local781 for (IWorker<ITestNGMethod> r : runnables) { in privateRun()