| /art/test/051-thread/src/ |
| Main.java | 23 * Test some basic thread stuff.
28 System.out.println("thread test starting");
36 System.out.println("thread test done");
40 * Simple thread capacity test.
48 for (TestCapacityThread thread : threads) {
49 thread.start();
51 for (TestCapacityThread thread : threads) {
52 thread.join();
55 System.out.println("testThreadCapacity thread count: " + TestCapacityThread.mCount);
58 private static class TestCapacityThread extends Thread {
126 Thread thread = new Thread() { local
[all...] |
| /external/junit/src/main/java/org/junit/internal/runners/statements/ |
| FailOnTimeout.java | 63 * thread. This can be useful for disabling timeouts in environments
100 Thread thread = new Thread(task, "Time-limited test"); local
101 thread.setDaemon(true);
102 thread.start();
104 Throwable throwable = getResult(task, thread);
115 private Throwable getResult(FutureTask<Throwable> task, Thread thread) {
123 return e; // caller will re-throw; no need to call Thread.interrupt(
[all...] |
| /external/mockftpserver/MockFtpServer/src/test/java/org/mockftpserver/core/session/ |
| DefaultSession_RunTest.java | 36 * Tests for the DefaultSession class that require the session (thread) to be running/active.
93 Thread thread = new Thread(session);
local
94 thread.start();
95 Thread.sleep(1000L);
98 thread.join();
219 * @throws InterruptedException - if the thread sleep is interrupted
225 Thread thread = new Thread(session); local
[all...] |
| /external/mockftpserver/branches/1.x_Branch/src/test/java/org/mockftpserver/core/session/ |
| DefaultSession_RunTest.java | 41 * Tests for the DefaultSession class that require the session (thread) to be running/active.
229 Thread thread = new Thread(session);
local
230 thread.start();
233 Thread.sleep(50L);
237 thread.join();
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| LocalLoadingCacheTest.java | 32 import java.lang.Thread.UncaughtExceptionHandler;
345 Thread thread = new Thread() { local
355 thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
357 public void uncaughtException(Thread t, Throwable e) {}
359 thread.start();
364 for (StackTraceElement trace : thread.getStackTrace()) {
|
| /art/runtime/native/ |
| dalvik_system_VMStack.cc | 39 typename std::result_of<T(Thread*, const ScopedFastNativeObjectAccess&)>::type>
49 // Never allow suspending the heap task thread since it may deadlock if allocations are
51 Thread* heap_task_thread =
57 // Suspend thread to build stack trace.
61 Thread* thread = thread_list->SuspendThreadByPeer(peer, local
65 if (thread != nullptr) {
69 trace = fn(thread, soa);
71 // Restart suspended thread.
72 bool resumed = thread_list->Resume(thread, SuspendReason::kInternal)
[all...] |
| /art/test/114-ParallelGC/src/ |
| Main.java | 24 // Timeout in minutes. Make it larger than the run-test timeout to get a native thread dump by
38 Thread[] threads = new Thread[THREAD_COUNT];
46 threads[i] = new Thread(new Main(startBarrier));
51 for (Thread thread : threads) {
52 thread.join();
131 System.out.println("Waited too long for the last thread.");
136 Thread.sleep(25);
|
| /bionic/libc/private/ |
| bionic_tls.h | 63 // The thread pointer (i.e. __get_tls()) points at &tls_slot(0).
68 // Initialize the main thread's final object using its bootstrap object.
74 pthread_internal_t* thread() { function in struct:bionic_tcb
93 /* Internally, jemalloc uses a single key for per thread data. */
110 // offset from the thread pointer).
131 // Initialize the main thread's final object using its bootstrap object.
|
| /bionic/tests/ |
| leak_test.cpp | 29 #include <thread>
113 pthread_t thread; local
114 ASSERT_EQ(0, pthread_create(&thread, nullptr, [](void*) -> void* { return nullptr; }, nullptr));
115 ASSERT_EQ(0, pthread_join(thread, nullptr));
145 pthread_t thread; local
146 ASSERT_EQ(0, pthread_create(&thread, nullptr, thread_function, &threads[i]));
147 ASSERT_EQ(0, pthread_detach(thread));
|
| pty_test.cpp | 125 // 2. Make master thread and slave thread running on different cpus:
126 // master thread uses first available cpu, and slave thread uses other cpus.
137 // 3. Create thread for slave reader.
138 pthread_t thread; local
142 ASSERT_EQ(0, pthread_create(&thread, nullptr,
152 // by the reader thread on another cpu.
162 ASSERT_EQ(0, pthread_join(thread, nullptr));
|
| /device/google/cuttlefish_common/guest/hals/gps/ |
| gps_thread.h | 38 // Control commands to GPS thread
46 pthread_t thread; member in struct:__anon2816
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_thread.py | 5 thread = test_support.import_module('thread')
variable
16 _print_mutex = thread.allocate_lock()
28 self.done_mutex = thread.allocate_lock()
30 self.running_mutex = thread.allocate_lock()
31 self.random_mutex = thread.allocate_lock()
43 thread.start_new_thread(self.task, (self.next_ident,))
59 # Basic test for thread creation.
68 self.assertEqual(thread.stack_size(), 0, "initial stack size is not 0")
70 thread.stack_size(0)
[all...] |
| /external/chromium-trace/catapult/systrace/atrace_helper/jni/ |
| atrace_process_dump.cc | 218 const ThreadInfo* thread = &(thread_it->second); local
219 fprintf(out_, "\"%d\":{", thread->tid);
220 fprintf(out_, "\"name\":\"%s\"", thread->name);
|
| /external/deqp/framework/delibs/dethread/unix/ |
| deThreadUnix.c | 2 * drawElements Thread Library
21 * \brief Unix implementation of thread management.
53 pthread_t thread; member in struct:Thread_s
56 } Thread;
58 DE_STATIC_ASSERT(sizeof(deThread) >= sizeof(Thread*));
62 Thread* thread = (Thread*)entryPtr; local
63 deThreadFunc func = thread->func;
64 void* arg = thread->arg
75 Thread* thread = (Thread*)deCalloc(sizeof(Thread)); local
114 Thread* thread = (Thread*)threadptr; local
132 Thread* thread = (Thread*)threadptr; local
[all...] |
| /external/jemalloc_new/include/jemalloc/internal/ |
| background_thread_structs.h | 16 /* Thread waits on the global lock when paused (for arena_reset). */
22 /* Background thread is pthread specific. */
23 pthread_t thread; member in struct:background_thread_info_s
33 * Since the last background thread run, newly added number of pages
36 * background thread to wake up earlier.
|
| tsd_generic.h | 9 pthread_t thread; member in struct:tsd_init_block_s
|
| /external/libchrome/base/threading/ |
| simple_thread.cc | 33 event_.Wait(); // Wait for the thread to complete initialization.
37 DCHECK(options_.joinable) << "A non-joinable thread can't be joined.";
38 DCHECK(HasStartBeenAttempted()) << "Tried to Join a never-started thread.";
39 DCHECK(!HasBeenJoined()) << "Tried to Join a thread multiple times.";
47 DCHECK(!HasStartBeenAttempted()) << "Tried to Start a thread multiple times.";
77 // We've initialized our new thread, signal that we're done to Start().
125 DelegateSimpleThread* thread = new DelegateSimpleThread(this, name_prefix_); local
126 thread->Start();
127 threads_.push_back(thread);
|
| /external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
| ExecutorFactoryTest.java | 40 private List<Thread> mThreadContainer;
48 mThreadContainer = new ArrayList<Thread>();
52 * Testing the {@link Executor} when called from the executor thread.
60 mThreadContainer.add(Thread.currentThread());
68 for (Thread thread : mThreadContainer) {
69 Assert.assertEquals(Thread.currentThread(), thread); local
74 * Testing the {@link Executor} when called from another thread.
88 mThreadContainer.add(Thread.currentThread())
112 Assert.assertEquals(Thread.currentThread(), thread); local
[all...] |
| /external/libxcam/xcore/ |
| thread_pool.cpp | 2 * thread_pool.cpp - Thread Pool
29 : public Thread
33 : Thread (name)
57 XCAM_LOG_DEBUG ("thread(%s, %p) stopped", XCAM_STR(get_name ()), this);
72 XCAM_LOG_DEBUG ("user thread(%s) get null data, need stop", XCAM_STR (_pool->get_name ()));
163 "thread pool(%s) start failed by creating user thread", XCAM_STR (get_name()));
217 SmartPtr<UserThread> thread = new UserThread (this, name); local
218 XCAM_ASSERT (thread.ptr ());
220 ERROR, thread.ptr () && thread->start (), XCAM_RETURN_ERROR_THREAD
[all...] |
| /external/ltp/testcases/kernel/sched/pthreads/ |
| pth_str02.c | 62 void *thread(void *);
94 thread(0);
104 | thread () |
110 void *thread(void *parm) function
136 pcrterr = pthread_create(&th, &attr, thread, (void *)(num + 1));
146 "Thread [%d]: unable to create more threads!",
|
| /external/ltp/testcases/kernel/syscalls/sched_setattr/ |
| sched_setattr01.c | 114 pthread_t thread; local
122 pthread_create(&thread, NULL, do_test, NULL);
123 pthread_join(thread, NULL);
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_getschedparam/ |
| stress.c | 20 * the queried thread.
94 pthread_t thread; member in struct:_tdata
99 /* Thread function */
110 ret = pthread_getschedparam(td[i].thread, &pol, &sp);
138 /* This thread does almost nothing but wait... */
226 "Failed to initialize thread attribute");
244 "failed to set thread attribute sched param");
251 "failed to set thread attribute sched prio");
254 ret = pthread_create(&td[i].thread, &ta[i], rt_thread, &bar);
258 "Failed to create a RT thread -- need more privilege?")
[all...] |
| /external/lzma/CPP/7zip/Bundles/SFXSetup/ |
| ExtractEngine.cpp | 7 #include "../../../Windows/Thread.h"
118 NWindows::CThread thread;
local
119 RINOK(thread.Create(CThreadExtracting::MyThreadFunction, &t));
123 t.ExtractCallbackSpec->StartProgressDialog(title, thread);
|
| /external/mesa3d/src/intel/vulkan/tests/ |
| block_pool_no_free.c | 33 pthread_t thread; member in struct:job
77 /* A list of indices, one per thread */
83 /* First, we find which thread has the highest next element */
124 pthread_create(&jobs[i].thread, NULL, alloc_blocks, &jobs[i]);
128 pthread_join(jobs[i].thread, NULL);
|
| state_pool_no_free.c | 33 pthread_t thread; member in struct:job
71 pthread_create(&jobs[i].thread, NULL, alloc_states, &jobs[i]);
75 pthread_join(jobs[i].thread, NULL);
77 /* A list of indices, one per thread */
83 /* First, we find which thread has the highest next element */
|
