Home
last modified time | relevance | path

Searched refs:Worker (Results 1 - 25 of 95) sorted by relevance

1234

/third_party/node/lib/internal/cluster/
H A Dworker.js12 module.exports = Worker;
14 // Common Worker implementation shared between the cluster primary and workers.
15 function Worker(options) { class
16 if (!(this instanceof Worker))
17 return new Worker(options);
40 ObjectSetPrototypeOf(Worker.prototype, EventEmitter.prototype);
41 ObjectSetPrototypeOf(Worker, EventEmitter);
43 Worker.prototype.kill = function() {
47 Worker.prototype.send = function() {
51 Worker
[all...]
H A Dchild.js16 const Worker = require('internal/cluster/worker');
32 cluster.Worker = Worker;
35 const worker = new Worker({
285 // Extend generic Worker with methods specific to worker processes.
286 Worker.prototype.disconnect = function() {
295 Worker.prototype.destroy = function() {
283 Worker.prototype.disconnect = function() { global() class
H A Dprimary.js24 const Worker = require('internal/cluster/worker');
38 cluster.Worker = Worker;
165 const worker = new Worker({
351 // Extend generic Worker with methods specific to the primary process.
352 Worker.prototype.disconnect = function() {
360 Worker.prototype.destroy = function(signo) {
349 Worker.prototype.disconnect = function() { global() class
/third_party/node/test/parallel/
H A Dtest-worker-unsupported-path.js6 const { Worker } = require('worker_threads');
14 assert.throws(() => { new Worker(existingRelPathNoDot); }, expectedErr);
15 assert.throws(() => { new Worker('relative_no_dot'); }, expectedErr);
16 assert.throws(() => { new Worker('file:///file_url'); }, expectedErr);
17 assert.throws(() => { new Worker('https://www.url.com'); }, expectedErr);
22 () => { new Worker('file:///file_url'); },
26 () => { new Worker('data:text/javascript,'); },
30 () => { new Worker('relative_no_dot'); },
41 assert.throws(() => { new Worker(new URL('https://www.url.com')); },
H A Dtest-worker-execargv-invalid.js5 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, {
H A Dtest-worker-workerdata-messageport.js7 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}`, {
H A Dtest-inspector-workers-flat-list.js6 const { Worker, isMainThread, parentPort, workerData } =
25 console.log(`Worker ${workerInfo.title} was reported`);
34 console.log(`Worker ${child} is running`);
45 const worker = new Worker(__filename, { workerData: 'launched by test' });
/third_party/node/src/
H A Dnode_worker.cc48 Worker::Worker(Environment* env, in Worker() function in node::worker::Worker
90 // Mark this Worker object as weak until we actually start the thread. in Worker()
96 bool Worker::is_stopped() const { in is_stopped()
103 void Worker::UpdateResourceConstraints(ResourceConstraints* constraints) { in UpdateResourceConstraints()
136 explicit WorkerThreadData(Worker* w) in WorkerThreadData()
166 isolate->AddNearHeapLimitCallback(Worker::NearHeapLimit, w); in WorkerThreadData()
193 Debug(w_, "Worker %llu dispose isolate", w_->thread_id_.id); in ~WorkerThreadData()
232 Worker* const w_;
237 friend class Worker;
[all...]
H A Dnode_worker.h27 class Worker : public AsyncWrap { class
29 Worker(Environment* env,
37 ~Worker() override;
56 SET_MEMORY_INFO_NAME(Worker)
57 SET_SELF_SIZE(Worker)
137 bool Worker::RequestInterrupt(Fn&& cb) { in RequestInterrupt()
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
H A Dscheduler.cpp105 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); in singleThreadedWorkers()
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()
234 MARL_ASSERT(worker != nullptr, "No Scheduler::Worker boun in Fiber()
363 Scheduler::Worker::Worker(Scheduler* scheduler, Mode mode, uint32_t id) Worker() function in marl::Scheduler::Worker
[all...]
/third_party/nghttp2/src/
H A Dshrpx_worker.cc63 auto worker = static_cast<Worker *>(w->data); in eventcb()
70 auto worker = static_cast<Worker *>(w->data); in mcpool_clear_cb()
83 auto worker = static_cast<Worker *>(w->data); in proc_wev_cb()
146 Worker::Worker(struct ev_loop *loop, SSL_CTX *sv_ssl_ctx, SSL_CTX *cl_ssl_ctx, in Worker() function in shrpx::Worker
243 void Worker::replace_downstream_config( in replace_downstream_config()
416 Worker::~Worker() { in ~Worker()
422 void Worker::schedule_clear_mcpool() { in schedule_clear_mcpool()
429 void Worker
[all...]
H A Dshrpx_quic_connection_handler.h48 class Worker;
53 CloseWait(Worker *worker, std::vector<ngtcp2_cid> scids,
61 Worker *worker;
82 QUICConnectionHandler(Worker *worker);
133 Worker *worker_;
H A Dshrpx_quic_listener.h35 class Worker;
39 QUICListener(const UpstreamAddr *faddr, Worker *worker);
45 Worker *worker_;
H A Dh2load.h71 struct Worker;
273 struct Worker { struct
309 Worker(uint32_t id, SSL_CTX *ssl_ctx, size_t nreq_todo, size_t nclients,
311 ~Worker();
312 Worker(Worker &&o) = default;
320 // This function frees a client from the list of clients for this Worker.
338 Worker *worker;
411 Client(uint32_t id, Worker *worker, size_t req_todo);
H A Dshrpx_client_handler.h51 class Worker;
63 ClientHandler(Worker *worker, int fd, SSL *ssl, const StringRef &ipaddr,
135 Worker *get_worker() const;
224 Worker *worker_;
H A Dshrpx_api_downstream_connection.h35 class Worker;
68 APIDownstreamConnection(Worker *worker);
103 Worker *worker_;
H A Dshrpx_live_check.h43 class Worker;
49 LiveCheck(struct ev_loop *loop, SSL_CTX *ssl_ctx, Worker *worker,
100 Worker *worker_;
H A Dshrpx_http_downstream_connection.h39 class Worker;
48 Worker *worker);
99 Worker *worker_;
/third_party/icu/ohos_icu4j/src/main/tests/ohos/global/icu/dev/test/translit/
H A DThreadTest.java28 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/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/
H A DThreadTest.java25 private ArrayList<Worker> threads = new ArrayList<Worker>();
36 Worker thread = new Worker(); in TestThreads()
41 for (Worker thread: threads) { in TestThreads()
59 private class Worker extends Thread { class in ThreadTest
/third_party/node/benchmark/misc/
H A Dstartup.js6 let Worker; // Lazy loaded in main
41 const child = new Worker(script);
44 throw new Error(`Worker stopped with exit code ${code}`);
64 Worker = require('worker_threads').Worker;
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
H A Dscheduler.h45 class Worker;
226 // Idle: the Fiber is currently unused, and sits in Worker::idleFibers,
235 // timeout. The fiber is stilling in the Worker::Work::waiting queue.
239 // Worker::Work::fibers queue.
271 Worker* const worker;
272 State state = State::Running; // Guarded by Worker's work.mutex.
325 // Once a task is started, it may yield to other tasks on the same Worker.
326 // Tasks are always resumed by the same Worker.
327 class Worker { class in marl::Scheduler
330 // Worker wil
[all...]
/third_party/node/benchmark/worker/
H A Dbench-eventlooputil.js4 const { Worker, parentPort } = require('worker_threads');
32 const worker = new Worker(__filename, { argv: ['idle cats'] });
44 const worker = new Worker(__filename, { argv: ['idle cats'] });
/third_party/benchmark/test/
H A Dinternal_threading_test.cc81 std::thread Worker(&MyBusySpinwait); in BM_WorkerThread()
82 Worker.join(); in BM_WorkerThread()
124 std::thread Worker(&MyBusySpinwait); in BM_MainThreadAndWorkerThread()
126 Worker.join(); in BM_MainThreadAndWorkerThread()
/third_party/node/lib/
H A Dworker_threads.js10 Worker,
35 Worker,

Completed in 14 milliseconds

1234