| /external/testng/src/test/java/test/thread/ |
| SequentialSample3Test.java | 1 package test.thread;
9 addId("SequentialSample3Test.f1()", Thread.currentThread().getId());
13 addId("SequentialSample3Test.f2()", Thread.currentThread().getId());
17 addId("SequentialSample3Test.f3()", Thread.currentThread().getId());
|
| SequentialSampleTest.java | 1 package test.thread;
9 addId("SequentialSampleTest.f1()", Thread.currentThread().getId());
13 addId("SequentialSampleTest.f2()", Thread.currentThread().getId());
17 addId("SequentialSampleTest.f3()", Thread.currentThread().getId());
|
| SingleThreadedSample2Test.java | 1 package test.thread;
10 addId("SingleThreadedSample2Test.f1()", Thread.currentThread().getId());
15 addId("SingleThreadedSample2Test.f2()", Thread.currentThread().getId());
20 addId("SingleThreadedSample2Test.f3()", Thread.currentThread().getId());
|
| SingleThreadedSample3Test.java | 1 package test.thread;
10 addId("SingleThreadedSample3Test.f1()", Thread.currentThread().getId());
15 addId("SingleThreadedSample3Test.f2()", Thread.currentThread().getId());
20 addId("SingleThreadedSample3Test.f3()", Thread.currentThread().getId());
|
| SingleThreadedSampleTest.java | 1 package test.thread;
10 addId("SingleThreadedSampleTest.f1()", Thread.currentThread().getId());
15 addId("SingleThreadedSampleTest.f2()", Thread.currentThread().getId());
20 addId("SingleThreadedSampleTest.f3()", Thread.currentThread().getId());
|
| ThreadPoolSizeBase.java | 1 package test.thread;
13 long n = Thread.currentThread().getId();
|
| ThreadPoolSizeTest.java | 1 package test.thread;
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| FileClientSessionCacheTest.java | 35 Thread[] threads = new Thread[10];
39 threads[i] = new Thread() {
48 for (Thread thread : threads) {
49 thread.start();
51 for (Thread thread : threads) {
52 thread.join();
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| MonitorInfoImpl.java | 39 ThreadReference thread; field in class:MonitorInfoImpl
43 ThreadReferenceImpl thread, int dpth) {
46 this.thread = thread;
48 thread.addListener(this);
64 "Invalid stack frame thread listener");
71 throw new InvalidStackFrameException("Thread has been resumed");
85 public ThreadReference thread() { method in class:MonitorInfoImpl
87 return thread;
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| SurfaceTextureHelper.java | 58 * made on a dedicated thread with a bound EGLContext. The thread will be the same throughout the
59 * lifetime of the SurfaceTextureHelper instance, but different from the thread calling the
61 * on the calling thread.
74 * |handler| is non-null, the callback will be executed on that handler's thread. If |handler| is
75 * null, a dedicated private thread is created for the callbacks.
83 final HandlerThread thread = new HandlerThread(TAG); local
84 thread.start();
85 finalHandler = new Handler(thread.getLooper());
87 // The onFrameAvailable() callback will be executed on the SurfaceTexture ctor thread. See
[all...] |
| /art/test/151-OpenFileLimit/src/ |
| Main.java | 46 // Now try to create a new thread.
48 Thread thread = new Thread() { local
50 System.out.println("thread run.");
53 thread.start();
54 thread.join();
|
| /external/opencensus-java/contrib/agent/src/integration-test/java/io/opencensus/contrib/agent/instrumentation/ |
| ThreadInstrumentationIT.java | 65 Thread thread = new Thread(runnable); local
67 thread.start();
68 thread.join();
80 class MyThread extends Thread {
90 Thread thread = new MyThread(); local
92 thread.start();
93 thread.join()
[all...] |
| /bionic/libc/bionic/ |
| __cxa_thread_atexit_impl.cpp | 42 pthread_internal_t* thread = __get_thread(); local
43 dtor->next = thread->thread_local_dtors;
44 thread->thread_local_dtors = dtor;
52 pthread_internal_t* thread = __get_thread(); local
53 while (thread->thread_local_dtors != nullptr) {
54 thread_local_dtor* current = thread->thread_local_dtors;
55 thread->thread_local_dtors = current->next;
|
| pthread_exit.cpp | 47 * and thread cancelation
52 pthread_internal_t* thread = __get_thread(); local
55 c->__cleanup_prev = thread->cleanup_stack;
56 thread->cleanup_stack = c;
61 pthread_internal_t* thread = __get_thread(); local
62 thread->cleanup_stack = c->__cleanup_prev;
73 pthread_internal_t* thread = __get_thread(); local
74 thread->return_value = return_value;
77 while (thread->cleanup_stack) {
78 __pthread_cleanup_t* c = thread->cleanup_stack
[all...] |
| pthread_internal.cpp | 45 pthread_t __pthread_internal_add(pthread_internal_t* thread) {
49 thread->next = g_thread_list;
50 thread->prev = nullptr;
51 if (thread->next != nullptr) {
52 thread->next->prev = thread;
54 g_thread_list = thread;
55 return reinterpret_cast<pthread_t>(thread);
58 void __pthread_internal_remove(pthread_internal_t* thread) {
61 if (thread->next != nullptr)
84 pthread_internal_t* thread = __pthread_internal_find(thread_id, caller); local
89 pthread_internal_t* thread = reinterpret_cast<pthread_internal_t*>(thread_id); local
[all...] |
| /cts/libs/vogar-expect/src/vogar/util/ |
| Threads.java | 34 public synchronized Thread newThread(Runnable r) {
35 Thread thread = new Thread(r, name + "-" + (nextId++)); local
36 thread.setDaemon(true);
37 return thread;
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread')
variable
51 thread.start_new(self.f, (i,))
|
| test_threadsignals.py | 8 thread = import_module('thread')
variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident())
[all...] |
| /external/clang/test/CodeGen/ |
| 2003-11-27-ConstructorCast.c | 13 struct thread_struct thread = (struct thread_struct) { {{0}} }; local
|
| 2003-11-27-UnionCtorInitialization.c | 15 struct thread_struct thread = (struct thread_struct) { {{0}} }; local
|
| /external/compiler-rt/test/asan/TestCases/Posix/ |
| deep_thread_stack.cc | 30 pthread_t thread; local
31 pthread_create(&thread, NULL, (callback_type)function, NULL);
32 pthread_join(thread, NULL);
50 // CHECK: WRITE of size 4 at 0x{{.*}} thread T[[ACCESS_THREAD:[0-9]+]]
51 // CHECK: freed by thread T[[FREE_THREAD:[0-9]+]] here:
52 // CHECK: previously allocated by thread T[[ALLOC_THREAD:[0-9]+]] here:
53 // CHECK: Thread T[[ACCESS_THREAD]] created by T[[ACCESS_RUNNER:[0-9]+]] here:
54 // CHECK: Thread T[[ACCESS_RUNNER]] created by T0 here:
55 // CHECK: Thread T[[FREE_THREAD]] created by T[[FREE_RUNNER:[0-9]+]] here:
56 // CHECK: Thread T[[FREE_RUNNER]] created by T0 here
[all...] |
| /external/compiler-rt/test/tsan/ |
| getline_nohang.cc | 13 void *thread(void *unused) { function
32 pthread_create(&t, &a, thread, NULL);
|
| /external/deqp/framework/delibs/destream/ |
| deStreamCpyThread.c | 21 * \brief Stream copying thread
30 deStreamCpyThread* thread = (deStreamCpyThread*)arg; local
31 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)thread->bufferSize);
39 readResult = deInStream_read(thread->input, buffer, thread->bufferSize, &read);
44 deOutStream_write(thread->output, buffer, read - written, &wrote);
56 deOutStream_flush(thread->output);
62 deStreamCpyThread* thread = malloc(sizeof(deStreamCpyThread)); local
64 DE_ASSERT(thread);
68 thread->input = input
[all...] |
| /external/grpc-grpc/src/core/tsi/ |
| alts_transport_security.h | 30 grpc_core::Thread thread; member in struct:alts_shared_resource
42 /* This method signals the thread that invokes grpc_tsi_alts_shutdown() to
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/tm/ |
| tm-vmx-unavail.c | 92 pthread_t *thread; local
99 thread = malloc(sizeof(pthread_t)*threads);
100 if (!thread)
104 pthread_create(&thread[i], NULL, &worker, NULL);
107 pthread_join(thread[i], NULL);
109 free(thread);
|
