Lines Matching defs:Worker
358 std::shared_ptr<Worker> GetWorkerFromInternalField(Isolate* isolate,
361 isolate->ThrowError("this is not a Worker");
367 isolate->ThrowError("Worker is defunct because main thread is terminating");
370 auto managed = i::Handle<i::Managed<Worker>>::cast(handle);
470 std::unordered_set<std::shared_ptr<Worker>> Shell::running_workers_;
2551 isolate->ThrowError("Worker must be constructed with new");
2556 // creating a new Worker (because the main thread is terminating) we can
2572 // The C++ worker object's lifetime is shared between the Managed<Worker>
2575 auto worker = std::make_shared<Worker>(*script);
2578 i::Handle<i::Object> managed = i::Managed<Worker>::FromSharedPtr(
2581 if (!Worker::StartWorkerThread(std::move(worker))) {
2597 std::shared_ptr<Worker> worker =
2616 std::shared_ptr<Worker> worker =
2634 std::shared_ptr<Worker> worker =
2644 std::shared_ptr<Worker> worker =
2977 global_template->Set(isolate, "Worker", Shell::CreateWorkerTemplate(isolate));
3019 String::NewFromUtf8Literal(isolate, "Worker"));
4109 Worker::Worker(const char* script) : script_(i::StrDup(script)) {
4113 Worker::~Worker() {
4122 bool Worker::is_running() const { return state_.load() == State::kRunning; }
4124 bool Worker::StartWorkerThread(std::shared_ptr<Worker> worker) {
4137 void Worker::WorkerThread::Run() {
4138 // Prevent a lifetime cycle from Worker -> WorkerThread -> Worker.
4152 std::shared_ptr<Worker> worker,
4161 std::shared_ptr<Worker> worker_;
4165 void Worker::PostMessage(std::unique_ptr<SerializationData> data) {
4176 std::shared_ptr<Worker> worker)
4180 auto expected = Worker::State::kTerminating;
4182 Worker::State::kTerminated));
4186 std::shared_ptr<Worker> worker_;
4189 std::unique_ptr<SerializationData> Worker::GetMessage() {
4200 void Worker::TerminateAndWaitForThread() {
4211 void Worker::Terminate() {
4224 void Worker::ProcessMessage(std::unique_ptr<SerializationData> data) {
4250 void Worker::ProcessMessages() {
4263 void Worker::ExecuteInThread() {
4276 // The Worker is now ready to receive messages.
4354 void Worker::PostMessageOut(const v8::FunctionCallbackInfo<v8::Value>& args) {
4370 Worker* worker = static_cast<Worker*>(this_value->Value());
5238 void Shell::AddRunningWorker(std::shared_ptr<Worker> worker) {
5243 void Shell::RemoveRunningWorker(const std::shared_ptr<Worker>& worker) {
5251 // Worker::Terminate while holding the workers_mutex_ lock. Otherwise, if a
5252 // worker is about to create a new Worker, it would deadlock.
5253 std::unordered_set<std::shared_ptr<Worker>> workers_copy;
5264 // Now that all workers are terminated, we can re-enable Worker creation.