| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| 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...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_threaded_import.py | 10 thread = import_module('thread') variable
12 critical_section = thread.allocate_lock()
13 done = thread.allocate_lock()
22 # thread can exit and set critical_section to None as part of global
45 # Tricky: When regrtest imports this module, the thread running regrtest
67 thread.start_new_thread(task, ())
|
| 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...] |
| /system/core/fastbootd/ |
| transport.c | 117 pthread_t thread; local
132 pthread_create(&thread, &attr, transport_data_thread, thandle);
142 pthread_t thread; local
148 pthread_create(&thread, &attr, transport_connect_thread, transport);
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| InterruptedStreamTest.java | 40 * Test that interrupting a thread blocked on I/O causes that thread to throw
52 Thread.interrupted();
61 Thread.interrupted(); // clear interrupted bit
121 Thread thread = interruptMeLater(); local
127 confirmInterrupted(thread);
132 Thread thread = interruptMeLater(); local
138 confirmInterrupted(thread);
143 Thread thread = interruptMeLater(); local
154 Thread thread = interruptMeLater(); local
167 Thread thread = interruptMeLater(); local
180 Thread thread = interruptMeLater(); local
195 Thread thread = new Thread(new Runnable () { local
[all...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| OldServerSocketChannelTest.java | 83 class MyThread extends Thread {
97 MyThread thread = new MyThread(); local
98 thread.start();
100 Thread.currentThread().sleep(TIME_UNIT);
101 thread.interrupt();
105 if (thread.errMsg != null) {
106 fail(thread.errMsg);
|
| /libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/ |
| CipherThread.java | 75 Thread thread = null; local
83 thread = new Thread(this);
84 thread.start();
86 thread.join();
|
| /libcore/luni/src/test/java/tests/api/java/lang/ |
| ProcessManagerTest.java | 33 Thread thread = null; field in class:ProcessManagerTest
62 thread = new Thread() {
79 Thread interruptThread = new Thread() {
87 thread.interrupt();
90 thread.start();
98 Thread.sleep(100);
103 thread.interrupt()
140 Thread thread = new Thread() { local
[all...] |
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/ |
| SelectorKernel.java | 63 private SelectorThread thread; field in class:SelectorKernel
89 if( thread != null )
92 thread = createSelectorThread();
95 thread.connect();
96 thread.start();
104 if( thread == null )
108 thread.close();
109 thread = null;
148 // SelectionKeys are dangerous outside the selector thread
186 thread.cancel(p)
[all...] |
| /external/guava/guava-tests/test/com/google/common/cache/ |
| LocalLoadingCacheTest.java | 34 import java.lang.Thread.UncaughtExceptionHandler;
318 Thread thread = new Thread() { local
328 thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
330 public void uncaughtException(Thread t, Throwable e) {}
332 thread.start();
337 for (StackTraceElement trace : thread.getStackTrace()) {
|
| /art/runtime/ |
| exception_test.cc | 29 #include "thread.h"
39 ScopedObjectAccess soa(Thread::Current());
141 Thread* thread = Thread::Current(); local
142 thread->TransitionFromSuspendedToRunnable();
145 JNIEnv* env = thread->GetJniEnv();
177 // Set up thread to appear as if we called out of method_g_ at pc dex 3
178 thread->SetTopOfStack(&fake_stack[0], method_g_->ToNativePc(dex_pc)); // return pc
194 thread->PushShadowFrame(reinterpret_cast<ShadowFrame*>(&fake_stack[5]))
[all...] |
| /bionic/libc/bionic/ |
| libc_init_common.cpp | 82 /* Init TLS for the initial thread. Called by the linker _before_ libc is mapped
86 * Note: this function creates a pthread_internal_t for the initial thread and
101 static pthread_internal_t thread; local
102 thread.tid = gettid();
103 thread.tls = tls;
104 pthread_attr_init(&thread.attr);
105 pthread_attr_setstack(&thread.attr, (void*) stack_bottom, stack_size);
106 _init_thread(&thread, false);
107 __init_tls(&thread);
122 // Get the main thread from TLS and add it to the thread list
[all...] |
| pthread_attr.cpp | 33 // Traditionally we give threads a 1MiB stack. When we started allocating per-thread
35 // same amount we were using there from the default thread stack size. This should
145 pthread_internal_t* thread = (pthread_internal_t*) thid; local
146 *attr = thread->attr;
|
| pthread_create.cpp | 59 void __init_tls(pthread_internal_t* thread) {
62 thread->tls[i] = NULL;
66 thread->tls[TLS_SLOT_SELF] = thread->tls;
67 thread->tls[TLS_SLOT_THREAD_ID] = thread;
69 thread->tls[TLS_SLOT_STACK_GUARD] = (void*) __stack_chk_guard;
71 __set_tls(thread->tls);
81 thread->alternate_signal_stack = ss.ss_sp;
89 // Wait for our creating thread to release us. This lets it have time t
97 pthread_internal_t* thread = (pthread_internal_t*) tls[TLS_SLOT_THREAD_ID]; local
173 pthread_internal_t* thread = reinterpret_cast<pthread_internal_t*>(calloc(sizeof(*thread), 1)); local
[all...] |
| /dalvik/vm/native/ |
| dalvik_system_VMStack.cpp | 130 * Return a trace buffer for the specified thread or NULL if the
131 * thread is not still alive. *depth is set to the length of a
137 Thread* self = dvmThreadSelf();
138 Thread* thread; local
146 * Make sure the thread is still alive and in the list.
148 for (thread = gDvm.threadList; thread != NULL; thread = thread->next)
[all...] |
| java_lang_VMThread.cpp | 25 * static void create(Thread t, long stacksize)
27 * This is eventually called as a result of Thread.start().
42 * static Thread currentThread()
55 * Gets the Thread status. Result is in VM terms, has to be mapped to
56 * Thread.State by interpreted code.
61 Thread* thread; local
65 thread = dvmGetThreadFromThreadObject(thisPtr);
66 if (thread != NULL)
67 result = thread->status
85 Thread* thread; local
108 Thread* thread; local
146 Thread* thread; local
170 Thread* thread; local
200 Thread* thread; local
[all...] |
| /external/chromium_org/android_webview/renderer/ |
| aw_content_renderer_client.cc | 52 RenderThread* thread = content::RenderThread::Get(); local
55 thread->AddObserver(aw_render_process_observer_.get());
58 thread->AddObserver(visited_link_slave_.get());
|
| /external/chromium_org/base/threading/ |
| simple_thread.cc | 31 DCHECK(!HasBeenStarted()) << "Tried to Start a thread multiple times.";
35 event_.Wait(); // Wait for the thread to complete initialization.
39 DCHECK(HasBeenStarted()) << "Tried to Join a never-started thread.";
40 DCHECK(!HasBeenJoined()) << "Tried to Join a thread multiple times.";
57 // We've initialized our new thread, signal that we're done to Start().
102 DelegateSimpleThread* thread = new DelegateSimpleThread(this, name_prefix_); local
103 thread->Start();
104 threads_.push_back(thread);
|
| /external/chromium_org/chrome/browser/spellchecker/ |
| spellcheck_message_filter_unittest.cc | 64 content::BrowserThread::ID thread; local
71 thread = content::BrowserThread::IO;
72 filter->OverrideThreadForMessage(message, &thread);
73 EXPECT_EQ(content::BrowserThread::UI, thread);
|
| /external/chromium_org/chrome/test/security_tests/ |
| ipc_security_tests.cc | 109 // This function is called from a thread that has a security context that is
118 // This is a pipe server thread routine.
168 // another thread which used to connect to the existing server pipe so the
185 HANDLE thread = ::CreateThread(NULL, 0, PipeServerProc, local
187 if (NULL == thread) {
190 ::CloseHandle(thread);
|
| /external/chromium_org/content/browser/ |
| power_save_blocker_mac.cc | 14 #include "base/threading/thread.h"
19 // Power management cannot be done on the UI thread. IOPMAssertionCreate does a
20 // synchronous MIG call to configd, so if it is called on the main thread the UI
27 static base::Thread* New(void* instance) {
28 base::Thread* thread = new (instance) base::Thread("PowerSaveBlocker"); local
29 thread->Start();
30 return thread;
32 static void Delete(base::Thread* instance) {
[all...] |
| /external/chromium_org/content/public/browser/ |
| browser_message_filter.cc | 42 BrowserThread::ID thread = BrowserThread::IO; local
43 OverrideThreadForMessage(message, &thread);
45 if (thread == BrowserThread::IO) {
59 if (thread == BrowserThread::UI && !CheckCanDispatchOnUI(message, this))
63 thread, FROM_HERE,
110 BrowserThread::ID* thread) {
130 // that can be answered on the IO thread.
131 NOTREACHED() << "Can't send sync messages to UI thread without pumping "
159 "Must handle messages that were dispatched to another thread!";
|
| /external/chromium_org/media/audio/ |
| audio_device_thread.cc | 22 // The actual worker thread implementation. It's very bare bones and much
24 // joining the thread handle asynchronously via a provided message loop even
25 // after the Thread object itself has been deleted.
26 class AudioDeviceThread::Thread
28 public base::RefCountedThreadSafe<AudioDeviceThread::Thread> {
30 Thread(AudioDeviceThread::Callback* callback,
36 // Stops the thread. If |loop_for_join| is non-NULL, the function posts
37 // a task to join (close) the thread handle later instead of waiting for
38 // the thread. If loop_for_join is NULL, then the function waits
39 // synchronously for the thread to terminate
119 base::PlatformThreadHandle thread = base::PlatformThreadHandle(); local
[all...] |
| /external/chromium_org/ppapi/native_client/tools/browser_tester/ |
| browser_tester.py | 11 import thread namespace
249 # is done in its own thread so the main thread can time out as needed.
253 thread.start_new_thread(Serve, ())
313 # the HTTP server thread to exit uncleanly with an EBADF error,
|
| /external/chromium_org/sandbox/win/sandbox_poc/pocdll/ |
| invasive.cc | 14 // entry point for the threads created by the thread bombing function.
30 // Create the thread and leak the handle.
31 HANDLE thread = ::CreateThread(NULL, // Default security attributes local
37 if (thread) {
38 fprintf(output, "[GRANTED] Creating thread with tid 0x%X\r\n", tid);
39 ::CloseHandle(thread);
42 fprintf(output, "[BLOCKED] Creating thread. Error %d\r\n",
56 // designed to take all CPU on the processor where the thread is running.
84 HANDLE thread = ::CreateThread(NULL, // Default security attributes. local
90 ::SetThreadAffinityMask(thread, affinity_mask)
[all...] |
