| /third_party/node/test/parallel/ |
| D | test-worker-unsupported-path.js | 6 const { Worker } = require('worker_threads');
13 assert.throws(() => { new Worker('/b'); }, expectedErr);
14 assert.throws(() => { new Worker('/c.wasm'); }, expectedErr);
15 assert.throws(() => { new Worker('/d.txt'); }, expectedErr);
16 assert.throws(() => { new Worker(new URL('file:///C:/e.wasm')); }, expectedErr);
25 assert.throws(() => { new Worker(existingRelPathNoDot); }, expectedErr);
26 assert.throws(() => { new Worker('relative_no_dot'); }, expectedErr);
27 assert.throws(() => { new Worker('file:///file_url'); }, expectedErr);
28 assert.throws(() => { new Worker('https://www.url.com'); }, expectedErr);
33 () => { new Worker('file:///file_url'); },
[all …]
|
| D | test-worker-data-url.js | 4 const { Worker } = require('worker_threads');
7 new Worker(new URL('data:text/javascript,'))
9 new Worker(new URL('data:text/javascript,export{}'))
12 new Worker(new URL('data:text/plain,'))
14 new Worker(new URL('data:text/javascript,module.exports={}'))
17 new Worker(new URL('data:text/javascript,await Promise.resolve()'))
19 new Worker(new URL('data:text/javascript,await Promise.reject()'))
21 new Worker(new URL('data:text/javascript,await new Promise(()=>{})'))
|
| D | test-worker-execargv-invalid.js | 5 const { Worker } = require('worker_threads');
14 new Worker(__filename, { execArgv: 'hello' });
17 new Worker(__filename, { execArgv: 6 });
27 new Worker(__filename, { execArgv: ['--foo'] });
30 new Worker(__filename, { execArgv: ['--title=blah'] });
33 new Worker(__filename, { execArgv: ['--redirect-warnings'] });
43 new Worker(__filename, {
|
| D | test-worker-process-argv.js | 4 const { Worker, isMainThread, workerData } = require('worker_threads');
8 new Worker(__filename, { argv: 'foo' });
14 new Worker(__filename, {
19 new Worker(`
28 new Worker(`
|
| D | test-worker-workerdata-messageport.js | 7 Worker, MessageChannel
17 new Worker(`${meowScript}`, { eval: true, workerData, transferList });
26 new Worker(`${meowScript}`, { eval: true, workerData, transferList });
32 new Worker(`
52 assert.throws(() => new Worker(`${meowScript}`, {
|
| D | test-worker-track-unmanaged-fds.js | 4 const { Worker } = require('worker_threads');
21 const w = new Worker(`${preamble}
32 const w = new Worker(`${preamble}
42 const w = new Worker(`${preamble}
59 const w = new Worker(`${preamble}
|
| D | test-cluster-worker-constructor.js | 31 worker = new cluster.Worker();
37 worker = new cluster.Worker({
47 worker = cluster.Worker.call({}, { id: 5 });
48 assert(worker instanceof cluster.Worker);
|
| D | test-worker-cleanexit-with-js.js | 11 const { Worker } = require('worker_threads');
17 new Worker(code, { eval: true });
19 new Worker(code, { eval: true }).on('online', common.mustCall((msg) => {
|
| D | test-worker-process-env.js | 5 const { Worker, workerData } = require('worker_threads');
13 new Worker(__filename, { workerData: 'runInWorker' })
21 new Worker(__filename, {
27 new Worker(__filename, { env: 42 });
|
| D | test-worker-nested-on-process-exit.js | 4 const { Worker, workerData } = require('worker_threads');
11 const w = new Worker(__filename, { workerData: nestedWorkerExitCounter });
16 const nestedWorker = new Worker('setInterval(() => {}, 100)', { eval: true });
|
| D | test-worker-environmentdata.js | 5 Worker,
23 new Worker(__filename);
32 new Worker(__filename);
|
| /third_party/node/lib/internal/cluster/ |
| D | worker.js | 10 module.exports = Worker;
13 function Worker(options) { class
14 if (!(this instanceof Worker))
15 return new Worker(options);
38 ObjectSetPrototypeOf(Worker.prototype, EventEmitter.prototype);
39 ObjectSetPrototypeOf(Worker, EventEmitter);
41 Worker.prototype.kill = function() {
45 Worker.prototype.send = function() {
49 Worker.prototype.isDead = function() {
53 Worker.prototype.isConnected = function() {
|
| /third_party/node/src/ |
| D | node_worker.cc | 45 Worker::Worker(Environment* env, in Worker() function in node::worker::Worker
89 bool Worker::is_stopped() const { in is_stopped()
96 void Worker::UpdateResourceConstraints(ResourceConstraints* constraints) { in UpdateResourceConstraints()
129 explicit WorkerThreadData(Worker* w) in WorkerThreadData()
164 isolate->AddNearHeapLimitCallback(Worker::NearHeapLimit, w); in WorkerThreadData()
230 Worker* const w_;
235 friend class Worker;
238 size_t Worker::NearHeapLimit(void* data, size_t current_heap_limit, in NearHeapLimit()
240 Worker* worker = static_cast<Worker*>(data); in NearHeapLimit()
248 void Worker::Run() { in Run()
[all …]
|
| D | node_worker.h | 24 class Worker : public AsyncWrap {
26 Worker(Environment* env,
32 ~Worker() override;
51 SET_MEMORY_INFO_NAME(Worker)
52 SET_SELF_SIZE(Worker)
132 bool Worker::RequestInterrupt(Fn&& cb) { in RequestInterrupt()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | scheduler.cpp | 105 auto worker = cfg.allocator->make_unique<Worker>( in bind()
106 this, Worker::Mode::SingleThreaded, -1); in bind()
115 auto worker = Worker::getCurrent(); in unbind()
141 cfg.allocator->create<Worker>(this, Worker::Mode::MultiThreaded, i);
170 Worker::getCurrent()->enqueue(std::move(task)); in enqueue()
191 if (auto worker = Worker::getCurrent()) { in enqueue()
205 bool Scheduler::stealWork(Worker* thief, uint64_t from, Task& out) { in stealWork()
233 : id(id), impl(std::move(impl)), worker(Worker::getCurrent()) { in Fiber()
241 auto worker = Worker::getCurrent(); in current()
250 MARL_ASSERT(worker == Worker::getCurrent(), in wait()
[all …]
|
| /third_party/nghttp2/src/ |
| D | shrpx_worker.cc | 49 auto worker = static_cast<Worker *>(w->data); in eventcb()
56 auto worker = static_cast<Worker *>(w->data); in mcpool_clear_cb()
69 auto worker = static_cast<Worker *>(w->data); in proc_wev_cb()
130 Worker::Worker(struct ev_loop *loop, SSL_CTX *sv_ssl_ctx, SSL_CTX *cl_ssl_ctx, in Worker() function in shrpx::Worker
204 void Worker::replace_downstream_config( in replace_downstream_config()
370 Worker::~Worker() { in ~Worker()
376 void Worker::schedule_clear_mcpool() { in schedule_clear_mcpool()
383 void Worker::wait() { in wait()
389 void Worker::run_async() { in run_async()
399 void Worker::send(const WorkerEvent &event) { in send()
[all …]
|
| D | h2load.h | 63 struct Worker;
243 struct Worker { struct
278 Worker(uint32_t id, SSL_CTX *ssl_ctx, size_t nreq_todo, size_t nclients, argument
280 ~Worker();
281 Worker(Worker &&o) = default;
307 Worker *worker;
342 Client(uint32_t id, Worker *worker, size_t req_todo);
|
| /third_party/node/test/addons/no-addons/ |
| D | test-worker.js | 8 const { Worker } = require('worker_threads');
22 const worker = new Worker(`require(${JSON.stringify(binding)})`, {
31 const worker = new Worker(
43 const worker = new Worker(`require(${JSON.stringify(binding)})`, {
53 const worker = new Worker(`require(${JSON.stringify(binding)})`, {
|
| /third_party/icu/ohos_icu4j/src/main/tests/ohos/global/icu/dev/test/translit/ |
| D | ThreadTest.java | 28 private ArrayList<Worker> threads = new ArrayList<Worker>();
39 Worker thread = new Worker(); in TestThreads()
44 for (Worker thread: threads) { in TestThreads()
62 private class Worker extends Thread { class in ThreadTest
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/docs/ |
| D | scheduler.md | 10 - [`marl::Scheduler::Worker::run()`](#marlschedulerworkerrun)
11 - [`marl::Scheduler::Worker::runUntilIdle()`](#marlschedulerworkerrununtilidle)
12 - [`marl::Scheduler::Worker::waitForWork()`](#marlschedulerworkerwaitforwork)
13 - [`marl::Scheduler::Worker::spinForWork()`](#marlschedulerworkerspinforwork)
14 - [`marl::Scheduler::Worker::suspend()`](#marlschedulerworkersuspend)
15 - [Worker Types](#worker-types)
35 …Worker](#single-threaded-workers) for the calling thread. This worker is used for scheduling tasks…
45 Each `marl::Scheduler::Fiber` is permanently associated with a `marl::Scheduler::Worker`, and is gu…
74 The scheduler holds a number of `marl::Scheduler::Worker`s. Each worker holds:
85 …Threads.count == 0`), then the task is queued on to the [Single-Threaded-Worker](#single-threaded-…
[all …]
|
| /third_party/boost/libs/thread/test/ |
| D | test_5542_1.cpp | 11 class Worker class
15 Worker() in Worker() function in Worker
23 m_Thread = boost::thread(&Worker::processQueue, this, N); in start()
56 Worker worker; in main()
|
| /third_party/node/doc/api/ |
| D | worker_threads.md | 1 # Worker threads
26 Worker, isMainThread, parentPort, workerData
32 const worker = new Worker(__filename, {
39 reject(new Error(`Worker stopped with exit code ${code}`));
50 The above example spawns a Worker thread for each `parse()` call. In actual
57 ["Using `AsyncResource` for a `Worker` thread pool"][async-resource-worker-pool]
60 Worker threads inherit non-process-specific options by default. Refer to
61 [`Worker constructor options`][] to know how to customize worker thread options,
77 Every new `Worker` receives its own copy of the environment data
82 Worker,
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| D | scheduler.h | 45 class Worker; variable
271 Worker* const worker;
327 class Worker {
337 Worker(Scheduler* scheduler, Mode mode, uint32_t id);
390 static inline Worker* getCurrent();
466 static thread_local Worker* current;
483 bool stealWork(Worker* thief, uint64_t from, Task& out);
500 std::array<Worker*, MaxWorkerThreads> workerThreads;
507 Allocator::unique_ptr<Worker>>;
572 Scheduler::Worker* Scheduler::Worker::getCurrent() { in getCurrent()
[all …]
|
| /third_party/typescript/tests/baselines/reference/ |
| D | verifyDefaultLib_webworker.symbols | 2 var x: Worker;
4 >Worker : Symbol(Worker, Decl(lib.webworker.d.ts, --, --), Decl(lib.webworker.d.ts, --, --))
|
| /third_party/node/benchmark/misc/ |
| D | startup.js | 6 let Worker; // Lazy loaded in main variable
27 return new Worker(script, { stderr: true, stdout: true });
73 Worker = require('worker_threads').Worker;
|