| /third_party/python/Lib/concurrent/futures/ |
| H A D | __init__.py | 49 from .thread import ThreadPoolExecutor as te
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/base/internal/ |
| H A D | per_thread_tls.h | 20 // If the platform supports thread-local storage:
23 // thread-local variable
31 // Microsoft C supports thread-local storage.
45 #define ABSL_PER_THREAD_TLS_KEYWORD __declspec(thread)
|
| /third_party/vk-gl-cts/framework/delibs/dethread/ |
| H A D | deThreadLocal.h | 32 # define DE_THREAD_LOCAL __declspec(thread)
|
| /third_party/node/src/ |
| H A D | node_process_methods.cc | 379 HANDLE thread = nullptr; in DebugProcess() local
387 if (thread != nullptr) CloseHandle(thread); in DebugProcess()
427 thread = in DebugProcess()
429 if (thread == nullptr) { in DebugProcess()
435 // Wait for the thread to terminate in DebugProcess()
436 if (WaitForSingleObject(thread, INFINITE) != WAIT_OBJECT_0) { in DebugProcess()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| H A D | scheduler.cpp | 21 #include "marl/thread.h"
55 // threadID() returns a uint64_t representing the currently executing thread.
59 return std::hash<std::thread::id>()(id); in threadID()
207 auto thread = workerThreads[from % cfg.workerThread.count]; in stealWork() local
208 if (thread != thief) { in stealWork()
209 if (thread->steal(out)) { in stealWork()
376 thread = Thread(std::move(affinity), [=] { in start()
411 thread.join(); in stop()
579 // starting the thread with a spinForWork(). in run()
|
| /third_party/pulseaudio/src/modules/ |
| H A D | module-waveout.c | 41 #include <pulsecore/thread.h>
42 #include <pulsecore/thread-mq.h>
76 pa_thread *thread; member
812 if (!(u->thread = pa_thread_new("waveout", thread_func, u))) { in pa__init()
813 pa_log("Failed to create thread."); in pa__init()
849 if (u->thread) in pa__done()
850 pa_thread_free(u->thread); in pa__done()
|
| /third_party/icu/icu4c/source/test/intltest/ |
| H A D | tsmthred.cpp | 127 errln("Error starting thread %d", i); in TestThreads()
223 errln("Error starting thread %d", i); in TestArabicShapingThreads()
272 // FormatThreadTest - a thread that tests performing a number of numberformats.
276 const int kFormatThreadIterations = 100; // # of iterations per thread
361 * Class for thread-safe testing of format.
364 * ThreadSafeFormat::doStuff() is called concurrently to test the thread safety of
369 /* give a unique offset to each thread */
681 errln("%s:%d System Error %d starting thread number %d.", in TestThreadedIntl()
908 errln("%s:%d THREAD INFO: thread %d failed to start with status %d", __FILE__, __LINE__, j, spawnResult); in TestCollators()
931 const int kStringThreadIterations = 2500;// # of iterations per thread
[all...] |
| /third_party/elfutils/libdwfl/ |
| H A D | dwfl_frame_pc.c | 40 ebl_normalize_pc (state->thread->process->ebl, pc); in dwfl_frame_pc()
|
| /third_party/FreeBSD/sys/dev/usb/ |
| H A D | usb_dynamic.h | 44 int fflag, struct thread *td);
|
| /third_party/mesa3d/src/util/ |
| H A D | u_qsort.cpp | 25 #include <thread>
|
| /third_party/musl/libc-test/src/functionalext/supplement/thread/thread_gtest/ |
| H A D | pthread_spin_test.cpp | 2 #include <thread>
|
| /third_party/skia/third_party/externals/spirv-cross/include/spirv_cross/ |
| H A D | barrier.hpp | 22 #include <thread>
|
| /third_party/libunwind/libunwind/doc/ |
| H A D | unw_init_remote.tex | 30 thread-id, or a pointer to an arbitrary structure which identifies the
49 \Func{unw\_init\_remote}() is thread-safe. If the local address-space
|
| /third_party/json/tests/thirdparty/Fuzzer/ |
| H A D | FuzzerUtil.cpp | 23 #include <thread>
199 unsigned N = std::thread::hardware_concurrency(); in NumberOfCpuCores()
201 Printf("WARNING: std::thread::hardware_concurrency not well defined for " in NumberOfCpuCores()
|
| /third_party/node/src/inspector/ |
| H A D | worker_agent.cc | 15 std::shared_ptr<MainThreadHandle> thread) in NodeWorkers()
16 : frontend_(frontend), thread_(thread) {} in NodeWorkers()
14 NodeWorkers(std::weak_ptr<NodeWorker::Frontend> frontend, std::shared_ptr<MainThreadHandle> thread) NodeWorkers() argument
|
| /third_party/musl/libc-test/src/regression/ |
| H A D | pthread_cond-smasher.c | 18 typedef pthread_t thread; typedef
63 static thread id[threads];
88 trace("thread %u in phase %u\n", *number, i); in client()
92 trace("thread %u is last, signalling main\n", *number); in client()
94 trace("thread %u is last, signalling main, %s\n", *number, errorstring(ret)); in client()
96 t_error("thread %u is last in phase %u, signalling main failed: %s\n", *number, i, errorstring(ret)); in client()
99 tell("thread %u in phase %u (%u), waiting\n", *number, i, phase); in client()
102 trace("thread %u in phase %u (%u), finished, %s\n", *number, i, phase, errorstring(ret)); in client()
104 t_error("thread %u in phase %u (%u) finished waiting: %s\n", *number, i, phase, errorstring(ret)); in client()
109 trace("thread in client()
[all...] |
| /third_party/ltp/testcases/realtime/func/prio-preempt/ |
| H A D | prio-preempt.c | 25 * The main thread:
37 * - Wakes up thread at priority 10 (T1) by executing:
46 * else the process continues with other threads. The thread T1 expects
139 tid = (intptr_t) (((struct thread *)arg)->arg); in busy_thread()
165 tid = (intptr_t) (((struct thread *)arg)->arg); in worker_thread()
188 /*check if we're the last thread */ in worker_thread()
197 /* Signal next thread */ in worker_thread()
237 /* start interrupter thread */ in master_thread()
278 printf("Signaling first thread\n"); in master_thread()
305 printf("Maximum busy thread coun in main()
[all...] |
| /third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/gl/egl/ |
| H A D | DisplayEGL.h | 14 #include <thread>
156 angle::HashMap<std::thread::id, CurrentNativeContext> mCurrentNativeContexts;
|
| /third_party/skia/third_party/externals/angle2/src/tests/perf_tests/ |
| H A D | ANGLEPerfTest.h | 17 #include <thread>
229 std::vector<std::thread::id> mThreadIDs;
|
| /third_party/skia/third_party/externals/oboe/src/common/ |
| H A D | AudioStream.cpp | 19 #include <thread>
44 int scheduler = sched_getscheduler(0) & ~SCHED_RESET_ON_FORK; // for current thread in checkScheduler()
206 // Stop this stream on a separate thread in launchStopThread()
207 std::thread t(oboe_stop_thread_proc, this); in launchStopThread()
|
| /third_party/skia/third_party/externals/angle2/src/tests/test_utils/runner/ |
| H A D | TestSuite.h | 17 #include <thread>
205 std::thread mWatchdogThread;
|
| /third_party/skia/third_party/externals/swiftshader/third_party/subzero/src/ |
| H A D | IceBrowserCompileServer.cpp | 35 #include <thread>
192 // Only kill the current thread instead of the whole process. We need the in fatalErrorHandler()
193 // server thread to remain alive in order to respond with the error message. in fatalErrorHandler()
257 // QueueStreamer. Otherwise the thread could become blocked. in pushInputBytes()
309 CompileThread = std::thread([this]() { in startCompileThread()
|
| /third_party/vk-gl-cts/framework/platform/android/ |
| H A D | tcuAndroidRenderActivity.cpp | 100 // Wait for thread to terminate in stop()
161 // thread will eventually kill the test, causing it to fail. We therefore in processMessage()
319 void RenderActivity::setThread (RenderThread* thread) in setThread() argument
321 m_thread = thread; in setThread()
376 m_thread->sync(); // Block until thread has processed all messages. in onNativeWindowDestroyed()
|
| /third_party/musl/src/thread/mips/ |
| H A D | clone.s | 6 # Save function pointer and argument pointer on new thread stack
|
| /third_party/libphonenumber/cpp/src/phonenumbers/base/memory/ |
| H A D | singleton_boost.h | 19 #include <boost/thread/once.hpp>
|