| /external/opencensus-java/exporters/stats/signalfx/src/main/java/io/opencensus/exporter/stats/signalfx/ |
| D | SignalFxStatsExporter.java | 45 private final SignalFxStatsExporterWorkerThread workerThread; field in SignalFxStatsExporter
54 this.workerThread = in SignalFxStatsExporter()
80 exporter.workerThread.start(); in create()
88 SignalFxStatsExporterWorkerThread workerThread = exporter.workerThread; in unsafeResetExporter() local
89 if (workerThread != null && workerThread.isAlive()) { in unsafeResetExporter()
91 workerThread.interrupt(); in unsafeResetExporter()
92 workerThread.join(); in unsafeResetExporter()
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | RefQueueWorker.java | 70 protected volatile Thread workerThread; field in RefQueueWorker
100 if (this.workerThread == null) { in run()
101 this.workerThread = Thread.currentThread(); in run()
104 while (this.workerThread == Thread.currentThread()) { in run()
125 Thread wt = this.workerThread; in shutdown()
127 this.workerThread = null; // indicate shutdown in shutdown()
140 return "RefQueueWorker::" + this.workerThread; in toString()
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | SpanExporterImpl.java | 40 private final Thread workerThread; field in SpanExporterImpl
83 workerThread.interrupt(); in shutdown()
87 this.workerThread = in SpanExporterImpl()
89 this.workerThread.start(); in SpanExporterImpl()
95 return workerThread; in getServiceExporterThread()
|
| /external/swiftshader/third_party/marl/src/ |
| D | scheduler.cpp | 74 if (cfg.workerThread.count > 0 && !cfg.workerThread.affinityPolicy) { in setConfigDefaults()
75 cfg.workerThread.affinityPolicy = marl::Thread::Affinity::Policy::anyOf( in setConfigDefaults()
139 for (int i = 0; i < cfg.workerThread.count; i++) {
143 for (int i = 0; i < cfg.workerThread.count; i++) {
160 for (int i = cfg.workerThread.count - 1; i >= 0; i--) { in ~Scheduler()
163 for (int i = cfg.workerThread.count - 1; i >= 0; i--) { in ~Scheduler()
173 if (cfg.workerThread.count > 0) { in enqueue()
181 idx = nextEnqueueIndex++ % cfg.workerThread.count; in enqueue()
206 if (cfg.workerThread.count > 0) { in stealWork()
207 auto thread = workerThreads[from % cfg.workerThread.count]; in stealWork()
[all …]
|
| D | scheduler_test.cpp | 48 ASSERT_EQ(gotCfg.workerThread.count, 10); in TEST_F()
|
| /external/webrtc/sdk/objc/api/peerconnection/ |
| D | RTCVideoSource+Private.h | 42 workerThread:(rtc::Thread *)workerThread;
|
| D | RTCVideoSource.mm | 53 workerThread:(rtc::Thread *)workerThread {
59 signalingThread, workerThread, objCVideoTrackSource)];
|
| D | RTCPeerConnectionFactory.mm | 235 workerThread:_workerThread.get()];
|
| /external/opencensus-java/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/ |
| D | StackdriverStatsExporter.java | 63 private final Thread workerThread; field in StackdriverStatsExporter
93 this.workerThread = new DaemonThreadFactory().newThread(worker); in StackdriverStatsExporter()
331 exporter.workerThread.start(); in createInternal()
|
| /external/webrtc/sdk/android/api/org/webrtc/ |
| D | PeerConnectionFactory.java | 57 @Nullable private volatile ThreadInfo workerThread; field in PeerConnectionFactory
491 workerThread = null; in dispose()
554 printStackTrace(workerThread, printNativeStackTraces); in printInternalStackTraces()
570 workerThread = ThreadInfo.getCurrent(); in onWorkerThreadReady()
571 staticWorkerThread = workerThread; in onWorkerThreadReady()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | scheduler.h | 70 WorkerThread workerThread; member
529 workerThread.count = count; in setWorkerThreadCount()
535 workerThread.initializer = initializer; in setWorkerThreadInitializer()
541 workerThread.affinityPolicy = policy; in setWorkerThreadAffinityPolicy()
|
| /external/swiftshader/third_party/marl/docs/ |
| D | scheduler.md | 224 …cted with a positive number of worker threads (`marl::Scheduler::Config::workerThread::count > 0`).
|
| /external/apache-http/api/ |
| D | current.txt | 2932 field @Deprecated protected volatile Thread workerThread;
|