| /external/webkit/WebCore/manual-tests/resources/ |
| DrawMessage.class | |
| /libcore/luni/src/test/java/tests/support/ |
| ThreadPool.java | 26 private LinkedList<Runnable> taskQueue;
38 taskQueue = new LinkedList<Runnable>();
44 public synchronized void runTask(Runnable task) {
54 protected synchronized Runnable getTask() throws InterruptedException {
62 return (Runnable) taskQueue.removeFirst();
99 Runnable task = null;
|
| /frameworks/base/voip/java/com/android/server/sip/ |
| SipSessionListenerProxy.java | 39 private void proxy(Runnable runnable) {
43 new Thread(runnable, "SipSessionCallbackThread").start();
48 proxy(new Runnable() {
62 proxy(new Runnable() {
75 proxy(new Runnable() {
89 proxy(new Runnable() {
102 proxy(new Runnable() {
115 proxy(new Runnable() {
129 proxy(new Runnable() {
[all...] |
| /libcore/luni/src/test/java/tests/api/java/util/concurrent/ |
| ThreadPoolExecutorSubclassTest.java | 36 CustomTask(final Runnable r, final V res) {
124 protected <V> RunnableFuture<V> newTaskFor(Runnable r, V v) {
132 BlockingQueue<Runnable> workQueue) {
140 BlockingQueue<Runnable> workQueue,
150 BlockingQueue<Runnable> workQueue,
159 BlockingQueue<Runnable> workQueue,
170 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
172 protected void beforeExecute(Thread t, Runnable r) {
175 protected void afterExecute(Runnable r, Throwable t) {
186 public Thread newThread(Runnable r)
[all...] |
| ThreadPoolExecutorTest.java | 27 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
29 protected void beforeExecute(Thread t, Runnable r) {
32 protected void afterExecute(Runnable r, Throwable t) {
42 public Thread newThread(Runnable r) {
50 * execute successfully executes a runnable
53 ThreadPoolExecutor p1 = new ThreadPoolExecutor(1, 1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
67 ThreadPoolExecutor p2 = new ThreadPoolExecutor(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
79 ThreadPoolExecutor p2 = new ThreadPoolExecutor(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
94 ThreadPoolExecutor p2 = new ThreadPoolExecutor(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
108 ThreadPoolExecutor p2 = new ThreadPoolExecutor(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10))
[all...] |
| /cts/tools/dx-tests/src/dxc/junit/opcodes/monitorenter/ |
| Test_monitorenter.java | 35 Runnable r1 = new TestRunnable(t1);
36 Runnable r2 = new TestRunnable(t1);
55 Runnable r1 = new TestRunnable2(t1, 10);
56 Runnable r2 = new TestRunnable2(t1, 20);
109 class TestRunnable implements Runnable {
124 class TestRunnable2 implements Runnable {
|
| /cts/tests/src/android/os/cts/ |
| TestThread.java | 19 * Thread class for executing a Runnable containing assertions in a separate thread.
20 * Uncaught exceptions in the Runnable are rethrown in the context of the the thread
25 private Runnable mTarget;
27 public TestThread(Runnable target) {
41 * Run the target Runnable object and wait until the test finish or throw
85 * Check whether there is an exception when running Runnable object.
|
| /external/guava/src/com/google/common/util/concurrent/ |
| ListenableFutureTask.java | 51 * given {@code Runnable}, and arrange that {@code get} will return the
54 * @param runnable the runnable task
59 * new ListenableFutureTask<Object>(runnable, null)}
60 * @throws NullPointerException if runnable is null
62 public ListenableFutureTask(Runnable runnable, V result) {
63 super(runnable, result);
66 public void addListener(Runnable listener, Executor exec) {
|
| AbstractListenableFuture.java | 33 * {@link #addListener(Runnable, Executor)} and {@link #done()} methods to it.
48 public void addListener(Runnable listener, Executor exec) {
|
| ExecutionList.java | 28 * <p>A list of ({@code Runnable}, {@code Executor}) pairs that guarantees
29 * that every {@code Runnable} that is added using the add method will be
31 * {@code Runnable}s added after {@code run} is called are still guaranteed to
38 public class ExecutionList implements Runnable {
44 // The list of runnable,executor pairs to execute. Only modified within
53 * Add the runnable/executor pair to the list of pairs to execute. Executes
56 public void add(Runnable runnable, Executor executor) {
61 Preconditions.checkNotNull(runnable, "Runnable was null.")
107 final Runnable runnable; field in class:ExecutionList.RunnableExecutorPair
[all...] |
| ListenableFuture.java | 33 * future.addListener(new Runnable() {
52 * The listener will be {@linkplain Executor#execute(Runnable) passed
67 public void addListener(Runnable listener, Executor exec);
|
| DaemonThreadFactory.java | 39 public Thread newThread(Runnable r) {
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.ddms/src/com/android/ide/eclipse/ddms/ |
| CommonAction.java | 29 private Runnable mRunnable;
63 * Sets the {@link Runnable}.
64 * @see ICommonAction#setRunnable(Runnable)
66 public void setRunnable(Runnable runnable) {
67 mRunnable = runnable;
|
| /external/emma/core/java13/com/vladium/util/exit/ |
| ExitHookManager.java | 29 public abstract boolean addExitHook (Runnable runnable);
30 public abstract boolean removeExitHook (Runnable runnable);
61 public synchronized boolean addExitHook (final Runnable runnable)
63 if ((runnable != null) && ! m_exitThreadMap.containsKey (runnable))
65 final Thread exitThread = new Thread (runnable, IAppConstants.APP_NAME + " shutdown handler thread");
70 m_exitThreadMap.put (runnable, exitThread); // TODO: use identity her
[all...] |
| /libcore/luni/src/main/java/java/util/ |
| SpecialAccess.java | 34 Runnable.class.getMethod("run", (Class[]) null);
|
| TimerTask.java | 27 public abstract class TimerTask implements Runnable {
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| CompletionService.java | 48 * Submits a Runnable task for execution and returns a Future
61 Future<V> submit(Runnable task, V result);
|
| ThreadPoolExecutor.java | 258 * protected void beforeExecute(Thread t, Runnable r) {
418 private final BlockingQueue<Runnable> workQueue;
555 implements Runnable
566 Runnable firstTask;
574 Worker(Runnable firstTask) {
793 final void reject(Runnable command) {
822 private List<Runnable> drainQueue() {
823 BlockingQueue<Runnable> q = workQueue;
824 List<Runnable> taskList = new ArrayList<Runnable>();
[all...] |
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| PriorityThreadFactory.java | 40 public Thread newThread(Runnable r) {
|
| /cts/tools/vm-tests/src/dot/junit/opcodes/monitor_enter/ |
| Test_monitor_enter.java | 35 Runnable r1 = new TestRunnable(t1);
36 Runnable r2 = new TestRunnable(t1);
55 Runnable r1 = new TestRunnable2(t1, 10);
56 Runnable r2 = new TestRunnable2(t1, 20);
148 class TestRunnable implements Runnable {
163 class TestRunnable2 implements Runnable {
|
| /packages/apps/Email/src/com/android/email/service/ |
| EmailServiceProxy.java | 56 private Runnable mRunnable;
87 new Thread(new Runnable() {
129 private void setTask(Runnable runnable) throws RemoteException {
133 mRunnable = runnable;
160 setTask(new Runnable () {
172 setTask(new Runnable () {
184 setTask(new Runnable () {
198 setTask(new Runnable () {
219 setTask(new Runnable () {
[all...] |
| /dalvik/dx/tests/070-dex-multianewarray/ |
| Blort.java | 95 public static Runnable[][][][][][] test18() {
96 return new Runnable[5][4][3][2][1][8];
|
| /frameworks/base/opengl/tests/testPauseResume/src/com/android/test/ |
| TestActivity.java | 29 Runnable mRunnable = new Runnable() {
|
| /libcore/luni/src/main/java/java/lang/ |
| Void.java | 41 Method method = Runnable.class.getMethod("run", new Class[0]);
|
| /libcore/luni/src/test/java/sun/misc/ |
| UnsafeTest.java | 39 Callable<Object> callable = Executors.callable(new Runnable() {
|
