| /external/tensorflow/tensorflow/python/ops/ |
| D | batch_ops_test.py | 71 worker_thread = threading.Thread(target=worker)
72 worker_thread.start()
74 worker_thread.join()
114 worker_thread = threading.Thread(target=worker)
115 worker_thread.start()
117 worker_thread.join()
150 worker_thread = threading.Thread(target=worker)
151 worker_thread.start()
153 worker_thread.join()
205 worker_thread = threading.Thread(target=worker)
[all …]
|
| /external/rust/crates/rayon-core/src/join/ |
| D | mod.rs | 132 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context()
138 worker_thread.push(job_b_ref); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
153 if let Some(job) = worker_thread.take_local_job() { in join_context()
161 worker_thread.execute(job); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
181 worker_thread: &WorkerThread, in join_recover_from_panic()
185 worker_thread.wait_until(job_b_latch); in join_recover_from_panic()
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 269 let worker_thread = WorkerThread::current(); in current() localVariable
270 if worker_thread.is_null() { in current()
273 (*worker_thread).registry.clone() in current()
283 let worker_thread = WorkerThread::current(); in current_num_threads() localVariable
284 if worker_thread.is_null() { in current_num_threads()
287 (*worker_thread).registry.num_threads() in current_num_threads()
367 let worker_thread = WorkerThread::current(); in inject_or_push() localVariable
369 if !worker_thread.is_null() && (*worker_thread).registry().id() == self.id() { in inject_or_push()
370 (*worker_thread).push(job_ref); in inject_or_push()
436 let worker_thread = WorkerThread::current(); in in_worker() localVariable
[all …]
|
| /external/webrtc/sdk/android/native_unittests/peerconnection/ |
| D | peer_connection_factory_unittest.cc | 37 rtc::Thread* worker_thread, in CreateTestPCF() argument
48 pcf_deps.worker_thread = worker_thread; in CreateTestPCF()
89 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in TEST() local
90 worker_thread->SetName("worker_thread", nullptr); in TEST()
91 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in TEST()
98 CreateTestPCF(jni, network_thread.get(), worker_thread.get(), in TEST()
102 jni, factory, std::move(network_thread), std::move(worker_thread), in TEST()
|
| /external/pdfium/third_party/libopenjpeg20/ |
| D | thread.c | 600 opj_worker_thread_t* worker_thread; member
622 opj_worker_thread_t* worker_thread,
658 opj_worker_thread_t* worker_thread; in opj_worker_thread_function() local
663 worker_thread = (opj_worker_thread_t*) user_data; in opj_worker_thread_function()
664 tp = worker_thread->tp; in opj_worker_thread_function()
668 opj_worker_thread_job_t* job = opj_thread_pool_get_next_job(tp, worker_thread, in opj_worker_thread_function()
759 opj_worker_thread_t* worker_thread, in opj_thread_pool_get_next_job() argument
792 if (!worker_thread->marked_as_waiting) { in opj_thread_pool_get_next_job()
795 worker_thread->marked_as_waiting = OPJ_TRUE; in opj_thread_pool_get_next_job()
808 item->worker_thread = worker_thread; in opj_thread_pool_get_next_job()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | rng.rs | 124 worker_thread: Option<thread::JoinHandle<Worker>>, field
135 worker_thread: None, in new()
149 if let Some(worker_thread) = self.worker_thread.take() { in drop()
150 let _ = worker_thread.join(); in drop()
221 self.worker_thread = Some(join_handle); in activate()
235 if let Some(worker_thread) = self.worker_thread.take() { in reset()
236 match worker_thread.join() { in reset()
|
| /external/webrtc/pc/ |
| D | video_rtp_receiver.cc | 32 VideoRtpReceiver::VideoRtpReceiver(rtc::Thread* worker_thread, in VideoRtpReceiver() argument
35 : VideoRtpReceiver(worker_thread, in VideoRtpReceiver()
40 rtc::Thread* worker_thread, in VideoRtpReceiver() argument
43 : worker_thread_(worker_thread), in VideoRtpReceiver()
48 worker_thread, in VideoRtpReceiver()
52 worker_thread, in VideoRtpReceiver()
54 worker_thread))), in VideoRtpReceiver()
58 worker_thread, in VideoRtpReceiver()
59 new rtc::RefCountedObject<JitterBufferDelay>(worker_thread))) { in VideoRtpReceiver()
|
| D | video_track.cc | 25 rtc::Thread* worker_thread) in VideoTrack() argument
27 worker_thread_(worker_thread), in VideoTrack()
96 rtc::Thread* worker_thread) { in Create() argument
98 new rtc::RefCountedObject<VideoTrack>(id, source, worker_thread); in Create()
|
| D | rtp_sender.cc | 108 RtpSenderBase::RtpSenderBase(rtc::Thread* worker_thread, in RtpSenderBase() argument
111 : worker_thread_(worker_thread), in RtpSenderBase()
114 RTC_DCHECK(worker_thread); in RtpSenderBase()
410 rtc::Thread* worker_thread, in Create() argument
415 new rtc::RefCountedObject<AudioRtpSender>(worker_thread, id, stats, in Create()
419 AudioRtpSender::AudioRtpSender(rtc::Thread* worker_thread, in AudioRtpSender() argument
423 : RtpSenderBase(worker_thread, id, set_streams_observer), in AudioRtpSender()
558 rtc::Thread* worker_thread, in Create() argument
562 new rtc::RefCountedObject<VideoRtpSender>(worker_thread, id, in Create()
566 VideoRtpSender::VideoRtpSender(rtc::Thread* worker_thread, in VideoRtpSender() argument
[all …]
|
| D | audio_rtp_receiver.cc | 31 AudioRtpReceiver::AudioRtpReceiver(rtc::Thread* worker_thread, in AudioRtpReceiver() argument
34 : AudioRtpReceiver(worker_thread, in AudioRtpReceiver()
39 rtc::Thread* worker_thread, in AudioRtpReceiver() argument
42 : worker_thread_(worker_thread), in AudioRtpReceiver()
44 source_(new rtc::RefCountedObject<RemoteAudioSource>(worker_thread)), in AudioRtpReceiver()
52 new rtc::RefCountedObject<JitterBufferDelay>(worker_thread))) { in AudioRtpReceiver()
|
| /external/crosvm/devices/src/virtio/vhost/user/vmm/ |
| D | wl.rs | 21 worker_thread: Option<thread::JoinHandle<Worker>>, field
50 worker_thread: None, in new()
127 self.worker_thread = Some(join_handle); in activate()
145 if let Some(worker_thread) = self.worker_thread.take() { in drop()
150 let _ = worker_thread.join(); in drop()
|
| D | console.rs | 20 worker_thread: Option<thread::JoinHandle<Worker>>, field
50 worker_thread: None, in new()
128 self.worker_thread = Some(join_handle); in activate()
150 if let Some(worker_thread) = self.worker_thread.take() { in drop()
151 let _ = worker_thread.join(); in drop()
|
| D | vsock.rs | 22 worker_thread: Option<thread::JoinHandle<Worker>>, field
54 worker_thread: None, in new()
68 if let Some(worker_thread) = self.worker_thread.take() { in drop()
69 let _ = worker_thread.join(); in drop()
147 self.worker_thread = Some(join_handle); in activate()
|
| D | mac80211_hwsim.rs | 38 worker_thread: Option<thread::JoinHandle<Worker>>, field
64 worker_thread: None, in new()
103 self.worker_thread = Some(join_handle); in activate_internal()
112 if let Some(worker_thread) = self.worker_thread.take() { in drop()
117 let _ = worker_thread.join(); in drop()
|
| D | block.rs | 30 worker_thread: Option<thread::JoinHandle<Worker>>, field
64 worker_thread: None, in new()
78 if let Some(worker_thread) = self.worker_thread.take() { in drop()
79 let _ = worker_thread.join(); in drop()
162 self.worker_thread = Some(join_handle); in activate()
|
| D | net.rs | 26 worker_thread: Option<thread::JoinHandle<Worker>>, field
63 worker_thread: None, in new()
77 if let Some(worker_thread) = self.worker_thread.take() { in drop()
78 let _ = worker_thread.join(); in drop()
160 self.worker_thread = Some(join_handle); in activate()
|
| D | fs.rs | 24 worker_thread: Option<thread::JoinHandle<Worker>>, field
70 worker_thread: None, in new()
161 self.worker_thread = Some(join_handle); in activate()
183 if let Some(worker_thread) = self.worker_thread.take() { in drop()
184 let _ = worker_thread.join(); in drop()
|
| D | gpu.rs | 40 worker_thread: Option<thread::JoinHandle<Worker>>, field
87 worker_thread: None, in new()
186 self.worker_thread = Some(join_handle); in activate()
250 if let Some(worker_thread) = self.worker_thread.take() { in drop()
255 let _ = worker_thread.join(); in drop()
|
| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 85 Thread worker_thread("worker thread"); in TEST_F() local
86 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
93 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
99 worker_thread.Stop(); in TEST_F()
165 Thread worker_thread("worker thread"); in TEST_F() local
166 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
169 worker_thread.task_runner().get(), FROM_HERE, DoNothing(), in TEST_F()
175 worker_thread.Stop(); in TEST_F()
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | mod.rs | 77 worker_thread: Option<thread::JoinHandle<bool>>, field
114 if self.worker_thread.is_some() { in activate()
182 self.worker_thread = Some(join_handle); in activate()
194 } else if let Some(worker_thread) = self.worker_thread.take() { in reset()
195 match worker_thread.join() { in reset()
223 worker_thread: None, in new_sound()
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | net.rs | 30 worker_thread: Option<thread::JoinHandle<(Worker<U>, T)>>, field
98 worker_thread: None, in new()
122 if let Some(worker_thread) = self.worker_thread.take() { in drop()
123 let _ = worker_thread.join(); in drop()
257 self.worker_thread = Some(join_handle); in activate()
279 if self.worker_thread.is_none() { in control_notify()
333 if let Some(worker_thread) = self.worker_thread.take() { in reset()
334 match worker_thread.join() { in reset()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 532 worker_thread: Option<thread::JoinHandle<Worker<T>>>, field
545 if let Some(worker_thread) = self.worker_thread.take() { in drop()
546 let _ = worker_thread.join(); in drop()
629 self.worker_thread = Some(join_handle); in activate()
645 if let Some(worker_thread) = self.worker_thread.take() { in reset()
646 match worker_thread.join() { in reset()
668 worker_thread: None, in new_evdev()
688 worker_thread: None, in new_single_touch()
708 worker_thread: None, in new_multi_touch()
729 worker_thread: None, in new_trackpad()
[all …]
|
| /external/bcc/tools/ |
| D | offcputime_example.txt | 354 worker_thread
361 worker_thread
368 worker_thread
375 worker_thread
382 worker_thread
389 worker_thread
396 worker_thread
471 worker_thread
563 worker_thread
681 kworker/6:2;ret_from_fork;kthread;worker_thread;schedule 3940583
[all …]
|
| /external/webrtc/sdk/android/src/jni/pc/ |
| D | peer_connection_factory.cc | 140 std::unique_ptr<rtc::Thread> worker_thread, in NativeToScopedJavaPeerConnectionFactory() argument
144 std::move(network_thread), std::move(worker_thread), in NativeToScopedJavaPeerConnectionFactory()
152 PostJavaCallback(env, owned_factory->worker_thread(), RTC_FROM_HERE, j_pcf, in NativeToScopedJavaPeerConnectionFactory()
180 std::unique_ptr<rtc::Thread> worker_thread, in NativeToJavaPeerConnectionFactory() argument
184 jni, pcf, std::move(network_thread), std::move(worker_thread), in NativeToJavaPeerConnectionFactory()
279 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in CreatePeerConnectionFactoryForJava() local
280 worker_thread->SetName("worker_thread", nullptr); in CreatePeerConnectionFactoryForJava()
281 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in CreatePeerConnectionFactoryForJava()
301 dependencies.worker_thread = worker_thread.get(); in CreatePeerConnectionFactoryForJava()
338 jni, factory, std::move(network_thread), std::move(worker_thread), in CreatePeerConnectionFactoryForJava()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | rtc_certificate_generator.cc | 47 Thread* worker_thread, in RTCCertificateGenerationTask() argument
52 worker_thread_(worker_thread), in RTCCertificateGenerationTask()
135 Thread* worker_thread) in RTCCertificateGenerator() argument
136 : signaling_thread_(signaling_thread), worker_thread_(worker_thread) { in RTCCertificateGenerator()
|