| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/asn1/der/ |
| DerUTCTimeEDTest.java | 120 Thread[] workers = new Thread[workersNumber]; local
122 workers[i] = new TestWorker();
125 workers[i].start();
128 workers[i].join();
|
| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/x509/ |
| PolicyQualifierInfoTest.java | 151 Thread[] workers = new Thread[workersNumber]; local
153 workers[i] = new TestWorker1(i);
156 workers[i].start();
159 workers[i].join();
169 Thread[] workers = new Thread[workersNumber]; local
171 workers[i] = new TestWorker2(i);
174 workers[i].start();
177 workers[i].join();
|
| /external/chromium/chrome/browser/sync/sessions/ |
| sync_session.h | 87 const std::vector<ModelSafeWorker*>& workers);
125 const std::vector<ModelSafeWorker*>& workers() const { return workers_; } function in class:browser_sync::sessions::SyncSession
158 // datatypes should be synced and which workers should be used when working
|
| /external/chromium/chrome/browser/sync/glue/ |
| sync_backend_host.h | 604 // We maintain ownership of all workers. In some cases, we need to ensure
605 // shutdown occurs in an expected sequence by Stop()ing certain workers.
613 WorkerMap workers; member in struct:browser_sync::SyncBackendHost::__anon3474
|
| /external/chromium/chrome/browser/sync/engine/ |
| syncer_thread.cc | 244 s->delegate(), s->source(), s->routing_info(), s->workers()));
287 old->source(), old->routing_info(), old->workers()));
395 s->source(), s->routing_info(), s->workers()));
405 // Helper to extract the routing info and workers corresponding to types in
409 std::vector<ModelSafeWorker*>* workers) {
427 iter it2 = std::find_if(workers->begin(), workers->end(),
429 if (it2 == workers->end())
430 workers->push_back(*it);
444 workers->push_back(*it)
458 std::vector<ModelSafeWorker*> workers; local
796 std::vector<ModelSafeWorker*> workers; local
[all...] |
| syncer_unittest.cc | 154 std::vector<ModelSafeWorker*> workers; local
156 GetWorkers(&workers);
161 info, workers);
[all...] |
| /external/chromium/chrome/browser/sync/ |
| profile_sync_service_autofill_unittest.cc | 587 std::vector<browser_sync::ModelSafeWorker*> workers; local
588 service_->GetBackendForTest()->GetWorkers(&workers);
602 std::vector<browser_sync::ModelSafeWorker*> workers; local
603 service_->GetBackendForTest()->GetWorkers(&workers);
[all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 51 int workers = 5; field in class:TestWebServer
409 if (pool.size() >= workers) {
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 295 * The workerCount is the number of workers that have been
301 * reported as the current size of the workers set.
409 * Lock held on access to workers set and related bookkeeping.
418 * ensuring workers set is stable while separately checking
427 private final HashSet<Worker> workers = new HashSet<Worker>(); field in class:ThreadPoolExecutor
488 * Core pool size is the minimum number of workers to keep alive
681 for (Worker w : workers)
697 for (Worker w : workers) {
717 * enabled but there are still other workers. In this case, at
721 * workers since shutdown began will also eventually exit
[all...] |
| /external/compiler-rt/lib/asan/tests/ |
| asan_test.cc | 1948 pthread_t workers[kNumWorkers], forker; local
[all...] |
| /external/webkit/Tools/DumpRenderTree/win/ |
| LayoutTestControllerWin.cpp | 264 COMPtr<IWebWorkersPrivate> workers; local
265 if (FAILED(WebKitCreateInstance(CLSID_WebWorkersPrivate, 0, __uuidof(workers), reinterpret_cast<void**>(&workers))))
268 if (FAILED(workers->workerThreadCount(&count)))
[all...] |
