| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ThreadFactoryBuilderTest.java | 25 import java.lang.Thread.UncaughtExceptionHandler;
44 @Override public void uncaughtException(Thread t, Throwable e) {
58 Thread thread = threadFactory.newThread(monitoredRunnable); local
59 checkThreadPoolName(thread, 1);
61 Thread defaultThread =
63 assertEquals(defaultThread.isDaemon(), thread.isDaemon());
64 assertEquals(defaultThread.getPriority(), thread.getPriority());
65 assertSame(defaultThread.getThreadGroup(), thread.getThreadGroup());
67 thread.getUncaughtExceptionHandler())
107 Thread thread = factory.newThread(monitoredRunnable); local
113 Thread thread = factory.newThread(monitoredRunnable); local
120 Thread thread = factory.newThread(monitoredRunnable); local
184 Thread thread = builder.setThreadFactory(backingThreadFactory).build() local
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldCookieHandlerTest.java | 45 class TestThread extends Thread {
61 TestThread thread = new TestThread(); local
63 thread.start();
65 thread.join();
|
| OldDatagramPacketTest.java | 32 Thread thread = new Thread(new Runnable() { local
40 System.out.println("thread exception: " + e);
44 thread.start();
|
| /libcore/luni/src/test/java/libcore/java/util/logging/ |
| OldLogRecordTest.java | 33 Thread.sleep(2);
52 // Create and start the thread
53 MockThread thread = new MockThread(); local
54 thread.start();
56 thread.join();
70 assertTrue(lr.getThreadID() != thread.lr.getThreadID());
72 assertTrue(thread.lr.getThreadID() != thread2.lr.getThreadID());
75 public class MockThread extends Thread {
76 public LogRecord lr = null; //will be update by the thread
83 lr = new LogRecord(Level.CONFIG, "msg thread");
[all...] |
| /libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/ |
| TestThread.java | 34 Thread thread = null; local
38 thread = new Thread(this);
39 thread.start();
41 thread.join();
|
| /frameworks/base/core/java/android/app/ |
| IntentService.java | 31 * thread, and stops itself when it runs out of work.
34 * from an application's main thread. The IntentService class exists to
37 * will receive the Intents, launch a worker thread, and stop the service as
40 * <p>All requests are handled on a single worker thread -- they may take as
73 * @param name Used to name the worker thread, important only for debugging.
107 HandlerThread thread = new HandlerThread("IntentService[" + mName + "]"); local
108 thread.start();
110 mServiceLooper = thread.getLooper();
150 * This method is invoked on the worker thread with a request to process.
152 * worker thread that runs independently from other application logic
[all...] |
| /frameworks/base/media/java/android/mtp/ |
| MtpServer.java | 37 Thread thread = new Thread(this, "MtpServer"); local
38 thread.start();
|
| /packages/services/Telecomm/src/com/android/server/telecom/ |
| AsyncRingtonePlayer.java | 32 * Plays the default ringtone. Uses {@link Ringtone} in a separate thread so that this class can be
33 * used from the main thread.
36 // Message codes used with the ringtone thread.
44 /** Handler running on the ringtone thread. */
47 /** The current ringtone. Only used by the ringtone thread. */
72 * Posts a message to the ringtone-thread handler. Creates the handler if specified by the
93 * Creates a new ringtone Handler running in its own thread.
98 HandlerThread thread = new HandlerThread("ringtone-player"); local
99 thread.start();
101 return new Handler(thread.getLooper())
[all...] |
| /art/compiler/llvm/ |
| runtime_support_builder_arm.cc | 20 #include "thread.h"
60 /* Thread */
65 CallInst* thread = irb_.CreateCall(func); local
66 thread->setDoesNotAccessMemory();
67 irb_.SetTBAA(thread, kTBAAConstJObject);
68 return thread;
98 Value* RuntimeSupportBuilderARM::EmitSetCurrentThread(Value* thread) {
100 // sets the current thread.
115 irb_.CreateCall(func, thread);
|
| runtime_support_builder_x86.cc | 21 #include "thread.h"
46 std::string inline_asm(StringPrintf("mov %%fs:%d, $0", Thread::SelfOffset().Int32Value()));
48 CallInst* thread = irb_.CreateCall(func); local
49 thread->setDoesNotAccessMemory();
50 irb_.SetTBAA(thread, kTBAAConstJObject);
51 return thread;
|
| /external/bluetooth/bluedroid/osi/test/ |
| reactor_test.cpp | 10 static pthread_t thread; variable
24 int ret = pthread_create(&thread, NULL, reactor_thread, reactor);
29 pthread_join(thread, NULL);
|
| /external/chromium_org/base/threading/ |
| platform_thread_unittest.cc | 12 // Trivial tests that thread runs and doesn't crash on create and join ---------
31 TrivialThread thread; local
34 ASSERT_FALSE(thread.did_run());
35 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle));
37 ASSERT_TRUE(thread.did_run());
41 TrivialThread thread[10]; local
42 PlatformThreadHandle handle[arraysize(thread)];
44 for (size_t n = 0; n < arraysize(thread); n++)
45 ASSERT_FALSE(thread[n].did_run());
46 for (size_t n = 0; n < arraysize(thread); n++
82 FunctionTestThread thread; local
98 FunctionTestThread thread[10]; local
[all...] |
| /external/chromium_org/content/renderer/ |
| render_thread_impl_browsertest.cc | 30 void CheckRenderThreadInputHandlerManager(RenderThreadImpl* thread) {
31 ASSERT_TRUE(thread->input_handler_manager());
34 // Check that InputHandlerManager outlives compositor thread because it uses
66 RenderThreadImpl* thread = new RenderThreadImpl(channel_id); local
67 thread->EnsureWebKitInitialized();
69 ASSERT_TRUE(thread->input_handler_manager());
71 thread->compositor_message_loop_proxy()->PostTask(
73 base::Bind(&CheckRenderThreadInputHandlerManager, thread));
|
| /external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
| create.c | 6 * thread.
51 * This function creates a thread running the start function,
54 * The identity of the new thread is returned
65 * pointer to the starting routine for the new thread
72 * This function creates a thread running the start function,
75 * The identity of the new thread is returned
79 * 0 successfully created thread,
86 pthread_t thread; local
114 if ((thread = ptw32_new ()).p == NULL)
119 tp = (ptw32_thread_t *) thread.p
[all...] |
| /external/chromium_org/ppapi/utility/threading/ |
| simple_thread.h | 19 // This class is a simple wrapper around a pthread/Windows thread that creates
20 // and runs a PPAPI message loop on that thread.
35 // Starts a thread and runs a message loop in it. If you need control over
37 // success, false if the thread is already running or couldn't be started.
40 // Posts a quit message to the message loop and blocks until the thread
41 // exits. Returns true on success. If the thread is not running, returns
45 // Normally you can just use Start() to start a thread, and then post work to
51 ThreadHandle thread() const { return thread_; } function in class:pp::SimpleThread
|
| /external/chromium_org/remoting/tools/ |
| breakpad_tester_win.cc | 73 base::win::ScopedHandle thread; local
74 thread.Set(CreateRemoteThread(process.Get(), NULL, 0, NULL, NULL, 0,
76 if (!thread.IsValid()) {
77 PLOG(ERROR) << "Failed to create a remote thread in " << pid;
|
| /external/chromium_org/sandbox/win/sandbox_poc/pocdll/ |
| processes_and_threads.cc | 76 HANDLE thread = ::OpenThread(THREAD_QUERY_INFORMATION, local
79 if (NULL == thread) {
83 fprintf(output, "[GRANTED] Found thread %d:%d and able to open it.\r\n",
86 ::CloseHandle(thread);
|
| /external/chromium_org/third_party/WebKit/Source/core/workers/ |
| SharedWorkerGlobalScope.cpp | 53 PassRefPtrWillBeRawPtr<SharedWorkerGlobalScope> SharedWorkerGlobalScope::create(const String& name, SharedWorkerThread* thread, PassOwnPtrWillBeRawPtr<WorkerThreadStartupData> startupData)
55 RefPtrWillBeRawPtr<SharedWorkerGlobalScope> context = adoptRefWillBeRefCountedGarbageCollected(new SharedWorkerGlobalScope(name, startupData->m_scriptURL, startupData->m_userAgent, thread, startupData->m_workerClients.release()));
60 SharedWorkerGlobalScope::SharedWorkerGlobalScope(const String& name, const KURL& url, const String& userAgent, SharedWorkerThread* thread, PassOwnPtrWillBeRawPtr<WorkerClients> workerClients)
61 : WorkerGlobalScope(url, userAgent, thread, monotonicallyIncreasingTime(), workerClients)
76 SharedWorkerThread* SharedWorkerGlobalScope::thread() function in class:WebCore::SharedWorkerGlobalScope
78 return static_cast<SharedWorkerThread*>(Base::thread());
|
| /external/chromium_org/third_party/WebKit/Source/platform/graphics/filters/ |
| ParallelJobs.h | 69 // The main thread can execute one job, so only create requestJobNumber - 1 threads.
71 OwnPtr<blink::WebThread> thread = adoptPtr(blink::Platform::current()->createThread("Unfortunate parallel worker")); local
72 m_threads.append(thread.release());
|
| /external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/linux/ |
| main.cc | 36 #include "talk/base/thread.h"
40 CustomSocketServer(talk_base::Thread* thread, GtkMainWnd* wnd)
41 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {}
51 // different thread. Alternatively we could look at merging the two loops
66 talk_base::Thread* thread_;
94 talk_base::Thread* thread = talk_base::Thread::Current(); local
95 CustomSocketServer socket_server(thread, &wnd)
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| testturnserver.h | 34 #include "talk/base/thread.h"
46 TestTurnServer(talk_base::Thread* thread,
49 : server_(thread) {
66 talk_base::Thread* thread = talk_base::Thread::Current(); local
69 thread->socketserver(), int_addr), proto);
74 thread->socketserver()->CreateAsyncSocket(SOCK_STREAM);
|
| /external/chromium_org/third_party/mesa/src/src/glx/apple/ |
| apple_glx_log.c | 76 uint64_t thread = 0; local
80 thread = (uint64_t)(uintptr_t)pthread_self();
83 pthread_threadid_np(NULL, &thread);
85 thread = (uint64_t)(uintptr_t)pthread_self();
88 pthread_threadid_np(NULL, &thread);
97 _asl_level_string(level), file, line, function, thread);
117 asprintf(&_thread, "%"PRIu64, thread);
119 asl_set(msg, "Thread", _thread);
|
| /external/chromium_org/third_party/npapi/npspy/extern/nspr/private/ |
| pprthred.h | 54 ** THREAD PRIVATE FUNCTIONS
58 ** Associate a thread object with an existing native thread.
59 ** "type" is the type of thread object to attach
60 ** "priority" is the priority to assign to the thread
65 ** function returns. The thread object is automatically destroyed.
68 ** thread. PR_Init does this automatically for the primordial thread.
75 ** Detach the nspr thread from the currently executing native thread
91 NSPR_API(PRUint32) PR_GetThreadID(PRThread *thread); variable
193 NSPR_API(void *) PR_GetSP(PRThread *thread); variable
218 NSPR_API(void*) GetExecutionEnvironment(PRThread *thread); variable
318 NSPR_API(void) PR_Mac_PostAsyncNotify(PRThread *thread); variable
[all...] |
| /external/chromium_org/third_party/webrtc/system_wrappers/source/ |
| thread_win.cc | 40 // Set the thread name to appear in the VS debugger.
134 // Wait up to 2 seconds for the thread to complete.
161 "Thread with name:%s started ", name_);
162 SetThreadName(-1, name_); // -1, set thread name for the calling thread.
165 "Thread without name started");
180 "Thread with name:%s stopped", name_);
183 "Thread without name stopped");
189 HANDLE thread = thread_; local
191 CloseHandle(thread);
[all...] |
| /external/chromium_org/ui/shell_dialogs/ |
| base_shell_dialog_win.cc | 9 #include "base/threading/thread.h"
65 base::Thread* BaseShellDialogImpl::CreateDialogThread() {
66 base::Thread* thread = new base::Thread("Chrome_ShellDialogThread"); local
67 thread->init_com_with_mta(false);
68 bool started = thread->Start();
70 return thread;
|
