| /external/testng/src/test/java/test/ant/ |
| D | MultipleThreadTest.java | 26 _threads.add(Thread.currentThread()); in recordThread00()
31 _threads.add(Thread.currentThread()); in recordThread01()
36 _threads.add(Thread.currentThread()); in recordThread02()
41 _threads.add(Thread.currentThread()); in recordThread03()
46 _threads.add(Thread.currentThread()); in recordThread04()
51 _threads.add(Thread.currentThread()); in recordThread05()
56 _threads.add(Thread.currentThread()); in recordThread06()
61 _threads.add(Thread.currentThread()); in recordThread07()
66 _threads.add(Thread.currentThread()); in recordThread08()
71 _threads.add(Thread.currentThread()); in recordThread09()
[all …]
|
| /external/guice/core/src/com/google/inject/internal/ |
| D | CycleDetectingLock.java | 148 final Thread currentThread = Thread.currentThread(); in lockOrDetectPotentialLocksCycle() local
152 lockThreadIsWaitingOn.put(currentThread, this); in lockOrDetectPotentialLocksCycle()
156 lockThreadIsWaitingOn.remove(currentThread); in lockOrDetectPotentialLocksCycle()
168 lockThreadIsWaitingOn.remove(currentThread); in lockOrDetectPotentialLocksCycle()
172 lockOwnerThread = currentThread; in lockOrDetectPotentialLocksCycle()
175 locksOwnedByThread.put(currentThread, this); in lockOrDetectPotentialLocksCycle()
183 final Thread currentThread = Thread.currentThread(); in unlock() local
189 lockOwnerThread == currentThread, in unlock()
201 locksOwnedByThread.remove(currentThread, this), in unlock()
203 if (locksOwnedByThread.get(currentThread).isEmpty()) { in unlock()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Callables.java | 85 Thread currentThread = Thread.currentThread();
86 String oldName = currentThread.getName();
87 boolean restoreName = trySetName(nameSupplier.get(), currentThread);
92 boolean unused = trySetName(oldName, currentThread);
115 Thread currentThread = Thread.currentThread();
116 String oldName = currentThread.getName();
117 boolean restoreName = trySetName(nameSupplier.get(), currentThread);
122 boolean unused = trySetName(oldName, currentThread);
131 private static boolean trySetName(final String threadName, Thread currentThread) {
137 currentThread.setName(threadName);
|
| D | Uninterruptibles.java | 68 Thread.currentThread().interrupt(); in awaitUninterruptibly()
110 Thread.currentThread().interrupt(); in awaitUninterruptibly()
151 Thread.currentThread().interrupt(); in awaitUninterruptibly()
171 Thread.currentThread().interrupt(); in joinUninterruptibly()
212 Thread.currentThread().interrupt(); in joinUninterruptibly()
247 Thread.currentThread().interrupt(); in getUninterruptibly()
318 Thread.currentThread().interrupt(); in getUninterruptibly()
337 Thread.currentThread().interrupt(); in takeUninterruptibly()
364 Thread.currentThread().interrupt(); in putUninterruptibly()
402 Thread.currentThread().interrupt(); in sleepUninterruptibly()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Callables.java | 85 Thread currentThread = Thread.currentThread();
86 String oldName = currentThread.getName();
87 boolean restoreName = trySetName(nameSupplier.get(), currentThread);
92 boolean unused = trySetName(oldName, currentThread);
115 Thread currentThread = Thread.currentThread();
116 String oldName = currentThread.getName();
117 boolean restoreName = trySetName(nameSupplier.get(), currentThread);
122 boolean unused = trySetName(oldName, currentThread);
131 private static boolean trySetName(final String threadName, Thread currentThread) {
137 currentThread.setName(threadName);
|
| D | Uninterruptibles.java | 66 Thread.currentThread().interrupt(); in awaitUninterruptibly()
95 Thread.currentThread().interrupt(); in awaitUninterruptibly()
124 Thread.currentThread().interrupt(); in awaitUninterruptibly()
144 Thread.currentThread().interrupt(); in joinUninterruptibly()
173 Thread.currentThread().interrupt(); in joinUninterruptibly()
208 Thread.currentThread().interrupt(); in getUninterruptibly()
252 Thread.currentThread().interrupt(); in getUninterruptibly()
271 Thread.currentThread().interrupt(); in takeUninterruptibly()
298 Thread.currentThread().interrupt(); in putUninterruptibly()
324 Thread.currentThread().interrupt(); in sleepUninterruptibly()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | CoroutineExceptionHandlerImpl.kt | 32 val currentThread = Thread.currentThread() in handleCoroutineExceptionImpl() constant
33 …currentThread.uncaughtExceptionHandler.uncaughtException(currentThread, handlerException(exception… in handleCoroutineExceptionImpl()
38 val currentThread = Thread.currentThread() in handleCoroutineExceptionImpl() constant
39 currentThread.uncaughtExceptionHandler.uncaughtException(currentThread, exception) in handleCoroutineExceptionImpl()
|
| D | CoroutineContext.kt | 68 val currentThread = Thread.currentThread() in toString() constant
69 val oldName = currentThread.name in toString()
72 currentThread.name = buildString(lastIndex + coroutineName.length + 10) { in toString()
83 Thread.currentThread().name = oldState in restoreThreadContext()
|
| /external/testng/src/test/java/test/testng56/ |
| D | ParallelTest.java | 14 System.out.println(Thread.currentThread().getId() + ":setup"); in setup()
19 System.out.println(Thread.currentThread().getId() + ":teardown"); in teardown()
24 System.out.println(Thread.currentThread().getId() + ":test1"); in test1()
29 System.out.println(Thread.currentThread().getId() + ":test2"); in test2()
34 System.out.println(Thread.currentThread().getId() + ":test3"); in test3()
39 System.out.println(Thread.currentThread().getId() + ":test4"); in test4()
44 System.out.println(Thread.currentThread().getId() + ":test5"); in test5()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestDispatchersTest.kt | 27 val mainThread = Thread.currentThread() in <lambda>()
31 assertSame(mainThread, Thread.currentThread()) in <lambda>()
36 assertNotSame(mainThread, Thread.currentThread()) in <lambda>()
38 assertSame(mainThread, Thread.currentThread()) in <lambda>()
41 assertNotSame(mainThread, Thread.currentThread()) in <lambda>()
43 assertSame(mainThread, Thread.currentThread()) in <lambda>()
47 assertSame(mainThread, Thread.currentThread()) in <lambda>()
49 assertSame(mainThread, Thread.currentThread()) in <lambda>()
|
| D | TestCoroutineDispatcherTest.kt | 107 val currentThread = Thread.currentThread() in whenDispatchCalled_runsOnCurrentThread() constant
113 assertNotSame(currentThread, Thread.currentThread()) in whenDispatchCalled_runsOnCurrentThread()
126 val currentThread = Thread.currentThread() in whenAllDispatchersMocked_runsOnSameThread() constant
132 assertSame(currentThread, Thread.currentThread()) in whenAllDispatchersMocked_runsOnSameThread()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | CallablesTest.java | 91 String oldName = Thread.currentThread().getName(); in testRenaming()
97 assertEquals(Thread.currentThread().getName(), newName.get()); in testRenaming()
102 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming()
107 String oldName = Thread.currentThread().getName(); in testRenaming_exceptionalReturn()
114 assertEquals(Thread.currentThread().getName(), newName.get()); in testRenaming_exceptionalReturn()
123 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming_exceptionalReturn()
142 final String oldName = Thread.currentThread().getName(); in testRenaming_noPermissions()
148 assertEquals(Thread.currentThread().getName(), oldName); in testRenaming_noPermissions()
153 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming_noPermissions()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | CallablesTest.java | 91 String oldName = Thread.currentThread().getName(); in testRenaming()
97 assertEquals(Thread.currentThread().getName(), newName.get()); in testRenaming()
102 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming()
107 String oldName = Thread.currentThread().getName(); in testRenaming_exceptionalReturn()
114 assertEquals(Thread.currentThread().getName(), newName.get()); in testRenaming_exceptionalReturn()
123 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming_exceptionalReturn()
142 final String oldName = Thread.currentThread().getName(); in testRenaming_noPermissions()
148 assertEquals(Thread.currentThread().getName(), oldName); in testRenaming_noPermissions()
153 assertEquals(oldName, Thread.currentThread().getName()); in testRenaming_noPermissions()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 19 val thread = Thread.currentThread() in <lambda>()
21 assertSame(thread, Thread.currentThread()) in <lambda>()
55 val currentThread = Thread.currentThread() in <lambda>() constant
56 … assertTrue(currentThread.name.startsWith(threadName), "Unexpected thread $currentThread") in <lambda>()
|
| D | FlowableContextTest.kt | 26 val mainThread = Thread.currentThread() in <lambda>()
27 val dispatcherThread = withContext(dispatcher) { Thread.currentThread() } in <lambda>()
30 assertEquals(dispatcherThread, Thread.currentThread()) in <lambda>()
39 assertEquals(mainThread, Thread.currentThread()) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 19 val thread = Thread.currentThread() in <lambda>()
21 assertSame(thread, Thread.currentThread()) in <lambda>()
55 val currentThread = Thread.currentThread() in <lambda>() constant
56 … assertTrue(currentThread.name.startsWith(threadName), "Unexpected thread $currentThread") in <lambda>()
|
| D | FlowableContextTest.kt | 26 val mainThread = Thread.currentThread() in <lambda>()
27 val dispatcherThread = withContext(dispatcher) { Thread.currentThread() } in <lambda>()
30 assertEquals(dispatcherThread, Thread.currentThread()) in <lambda>()
39 assertEquals(mainThread, Thread.currentThread()) in <lambda>()
|
| /external/opencensus-java/contrib/agent/src/integration-test/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationIT.java | 62 final Thread callerThread = Thread.currentThread(); in execute()
72 assertThat(Thread.currentThread()).isNotSameAs(callerThread); in execute()
84 final Thread callerThread = Thread.currentThread(); in submit_Callable()
95 assertThat(Thread.currentThread()).isNotSameAs(callerThread); in submit_Callable()
110 final Thread callerThread = Thread.currentThread(); in submit_Runnable()
121 assertThat(Thread.currentThread()).isNotSameAs(callerThread); in submit_Runnable()
134 final Thread callerThread = Thread.currentThread(); in submit_RunnableWithResult()
146 assertThat(Thread.currentThread()).isNotSameAs(callerThread); in submit_RunnableWithResult()
161 final Thread callerThread = Thread.currentThread(); in currentContextExecutor()
185 assertThat(Thread.currentThread()).isNotSameAs(callerThread); in currentContextExecutor()
|
| /external/webrtc/rtc_base/java/src/org/webrtc/ |
| D | ThreadUtils.java | 26 @Nullable private Thread thread = Thread.currentThread();
30 thread = Thread.currentThread(); in checkIsOnValidThread()
32 if (Thread.currentThread() != thread) { in checkIsOnValidThread()
46 if (Thread.currentThread() != Looper.getMainLooper().getThread()) { in checkIsOnMainThread()
78 Thread.currentThread().interrupt(); in executeUninterruptibly()
100 Thread.currentThread().interrupt(); in joinUninterruptibly()
142 Thread.currentThread().interrupt(); in awaitUninterruptibly()
152 if (handler.getLooper().getThread() == Thread.currentThread()) { in invokeAtFrontUninterruptibly()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | VirtualTimeSource.kt | 46 private val mainThread: Thread = Thread.currentThread() in toString()
83 val status = threads.getOrPut(Thread.currentThread()) { ThreadStatus() }!! in toString()
89 val currentThread = Thread.currentThread() in toString() constant
90 val status = threads[currentThread]!! in toString()
92 threads.remove(currentThread) in toString()
99 val status = threads[Thread.currentThread()]!! in toString()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 82 val thread = Thread.currentThread() in <lambda>()
84 assertSame(thread, Thread.currentThread()) in <lambda>()
118 val currentThread = Thread.currentThread() in <lambda>() constant
119 … assertTrue(currentThread.name.startsWith(threadName), "Unexpected thread $currentThread") in <lambda>()
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| D | SimplePerRealmReloadingClassLoader.java | 87 ClassLoader current = Thread.currentThread().getContextClassLoader(); in doInRealm()
89 Thread.currentThread().setContextClassLoader(this); in doInRealm()
96 Thread.currentThread().setContextClassLoader(current); in doInRealm()
103 ClassLoader current = Thread.currentThread().getContextClassLoader(); in doInRealm()
105 Thread.currentThread().setContextClassLoader(this); in doInRealm()
112 Thread.currentThread().setContextClassLoader(current); in doInRealm()
|
| /external/jimfs/jimfs/src/main/java/com/google/common/jimfs/ |
| D | JimfsFileChannel.java | 122 blockingThreads.add(Thread.currentThread()); in beginBlocking()
136 blockingThreads.remove(Thread.currentThread()); in endBlocking()
167 Thread.currentThread().interrupt(); in read()
204 Thread.currentThread().interrupt(); in read()
237 Thread.currentThread().interrupt(); in read()
272 Thread.currentThread().interrupt(); in write()
310 Thread.currentThread().interrupt(); in write()
348 Thread.currentThread().interrupt(); in write()
369 Thread.currentThread().interrupt(); in write()
442 Thread.currentThread().interrupt(); in size()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxContextTest.kt | 26 val mainThread = Thread.currentThread() in <lambda>()
27 val dispatcherThread = withContext(dispatcher) { Thread.currentThread() } in <lambda>()
30 assertEquals(dispatcherThread, Thread.currentThread()) in <lambda>()
39 assertEquals(mainThread, Thread.currentThread()) in <lambda>()
|
| D | FlowAsFluxTest.kt | 78 val thread = Thread.currentThread() in <lambda>()
80 assertSame(thread, Thread.currentThread()) in <lambda>()
114 val currentThread = Thread.currentThread() in <lambda>() constant
115 … assertTrue(currentThread.name.startsWith(threadName), "Unexpected thread $currentThread") in <lambda>()
|