| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ThreadLocalStressTest.kt | 16 private val threadLocal = ThreadLocal<String>() constant in kotlinx.coroutines.ThreadLocalStressTest
35 withContext(Dispatchers.Default + threadLocal.asContextElement("bar")) { in <lambda>()
46 assertEquals(expectedValue, threadLocal.get()) in doStress()
67 withContext(threadLocal.asContextElement("foo")) { in doStress()
73 assertEquals(expectedValue, threadLocal.get()) in doStress()
88 { threadLocal.set(null) }) { threadLocal.get() == null } in testNonDispatcheableLeak()
89 assertNull(threadLocal.get()) in testNonDispatcheableLeak()
96 … doTestWithPreparation(::doTest, { threadLocal.set("initial") }) { threadLocal.get() == "initial" } in testNonDispatcheableLeakWithInitial()
97 assertEquals("initial", threadLocal.get()) in testNonDispatcheableLeakWithInitial()
106 { threadLocal.set(null) }) { threadLocal.get() == null } in testNonDispatcheableLeakWithContextSwitch()
[all …]
|
| D | UnconfinedConcurrentStressTest.kt | 15 private val threadLocal = ThreadLocal<Int>() in <lambda>() constant
32 threadLocal.set(0) in <lambda>()
34 assertEquals(0, threadLocal.get()) in <lambda>()
36 assertEquals(id, threadLocal.get()) in <lambda>()
39 threadLocal.set(id) in <lambda>()
|
| /external/deqp/framework/delibs/dethread/win32/ |
| D | deThreadLocalWin32.c | 42 void deThreadLocal_destroy (deThreadLocal threadLocal) in deThreadLocal_destroy() argument
44 DE_ASSERT(threadLocal != 0); in deThreadLocal_destroy()
45 TlsFree((DWORD)threadLocal); in deThreadLocal_destroy()
48 void* deThreadLocal_get (deThreadLocal threadLocal) in deThreadLocal_get() argument
50 DE_ASSERT(threadLocal != 0); in deThreadLocal_get()
51 return TlsGetValue((DWORD)threadLocal); in deThreadLocal_get()
54 void deThreadLocal_set (deThreadLocal threadLocal, void* value) in deThreadLocal_set() argument
56 DE_ASSERT(threadLocal != 0); in deThreadLocal_set()
57 TlsSetValue((DWORD)threadLocal, value); in deThreadLocal_set()
|
| /external/deqp/framework/delibs/dethread/unix/ |
| D | deThreadLocalUnix.c | 43 DE_INLINE pthread_key_t threadLocalToKey (deThreadLocal threadLocal) in threadLocalToKey() argument
45 DE_ASSERT(threadLocal != 0); in threadLocalToKey()
46 return (pthread_key_t)(threadLocal - 1); in threadLocalToKey()
57 void deThreadLocal_destroy (deThreadLocal threadLocal) in deThreadLocal_destroy() argument
60 ret = pthread_key_delete(threadLocalToKey(threadLocal)); in deThreadLocal_destroy()
65 void* deThreadLocal_get (deThreadLocal threadLocal) in deThreadLocal_get() argument
67 return pthread_getspecific(threadLocalToKey(threadLocal)); in deThreadLocal_get()
70 void deThreadLocal_set (deThreadLocal threadLocal, void* value) in deThreadLocal_set() argument
73 ret = pthread_setspecific(threadLocalToKey(threadLocal), value); in deThreadLocal_set()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | SharingWorkerClassTest.kt | 12 private val threadLocal = ThreadLocal<Int?>() constant in kotlinx.coroutines.scheduling.SharingWorkerClassTest
21 assertNull(threadLocal.get()) in <lambda>()
22 threadLocal.set(239) in <lambda>()
24 assertNull(threadLocal.get()) in <lambda>()
25 threadLocal.set(42) in <lambda>()
28 assertEquals(239, threadLocal.get()) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | ThreadContext.kt | 101 internal data class ThreadLocalKey(private val threadLocal: ThreadLocal<*>) : CoroutineContext.Key<… constant in ThreadLocalKey
105 private val threadLocal: ThreadLocal<T> constant in ThreadLocalElement
107 override val key: CoroutineContext.Key<*> = ThreadLocalKey(threadLocal)
110 val oldState = threadLocal.get() in updateThreadContext()
111 threadLocal.set(value) in updateThreadContext()
116 threadLocal.set(oldState) in restoreThreadContext()
129 override fun toString(): String = "ThreadLocal(value=$value, threadLocal = $threadLocal)"
|
| /external/robolectric/utils/src/main/java/org/robolectric/util/ |
| D | SoftThreadLocal.java | 13 private final ThreadLocal<SoftReference<T>> threadLocal = field in SoftThreadLocal
17 T item = threadLocal.get().get(); in get()
20 threadLocal.set(new SoftReference<>(item)); in get()
26 threadLocal.set(new SoftReference<>(item)); in set()
|
| /external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
| D | SoftThreadLocal.java | 12 private final ThreadLocal<SoftReference<T>> threadLocal = new ThreadLocal<SoftReference<T>>() { field in SoftThreadLocal
19 T item = threadLocal.get().get(); in get()
22 threadLocal.set(new SoftReference<>(item)); in get()
28 threadLocal.set(new SoftReference<>(item)); in set()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-context-11.kt | 10 val threadLocal = ThreadLocal<String?>() // declare thread-local variable constant
13 threadLocal.set("main") in <lambda>()
15 val job = launch(Dispatchers.Default + threadLocal.asContextElement(value = "launch")) { in <lambda>()
|
| /external/deqp/framework/delibs/dethread/ |
| D | deThreadLocal.h | 42 void deThreadLocal_destroy (deThreadLocal threadLocal);
44 void* deThreadLocal_get (deThreadLocal threadLocal);
45 void deThreadLocal_set (deThreadLocal threadLocal, void* value);
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | FutureTest.kt | 273 private val threadLocal = ThreadLocal<String>() in <lambda>() constant in kotlinx.coroutines.future.FutureTest
278 … val future = CompletableFuture.supplyAsync(Supplier { threadLocal.set("value") }, it.executor) in <lambda>()
281 threadLocal.get() in <lambda>()
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowRenderNodeAnimatorR.java | 134 void setAnimationHelper(ThreadLocal<?> threadLocal); in setAnimationHelper() argument
|
| D | ShadowRenderNodeAnimator.java | 139 void setAnimationHelper(ThreadLocal<?> threadLocal); in setAnimationHelper() argument
|
| D | ShadowViewRootImpl.java | 298 void setRunQueues(ThreadLocal<HandlerActionQueue> threadLocal); in setRunQueues() argument
|