#include "src/libplatform/default-job.h"
#include "src/base/bits.h"
#include "src/base/macros.h"
namespace v8 {
namespace platform {
namespace {
constexpr size_t kMaxWorkersPerJob = …;
}
DefaultJobState::JobDelegate::~JobDelegate() { … }
uint8_t DefaultJobState::JobDelegate::GetTaskId() { … }
DefaultJobState::DefaultJobState(Platform* platform,
std::unique_ptr<JobTask> job_task,
TaskPriority priority,
size_t num_worker_threads)
: … { … }
DefaultJobState::~DefaultJobState() { … }
void DefaultJobState::NotifyConcurrencyIncrease() { … }
uint8_t DefaultJobState::AcquireTaskId() { … }
void DefaultJobState::ReleaseTaskId(uint8_t task_id) { … }
void DefaultJobState::Join() { … }
void DefaultJobState::CancelAndWait() { … }
void DefaultJobState::CancelAndDetach() { … }
bool DefaultJobState::IsActive() { … }
bool DefaultJobState::CanRunFirstTask() { … }
bool DefaultJobState::DidRunTask() { … }
size_t DefaultJobState::CappedMaxConcurrency(size_t worker_count) const { … }
void DefaultJobState::CallOnWorkerThread(TaskPriority priority,
std::unique_ptr<Task> task) { … }
void DefaultJobState::UpdatePriority(TaskPriority priority) { … }
DefaultJobHandle::DefaultJobHandle(std::shared_ptr<DefaultJobState> state)
: … { … }
DefaultJobHandle::~DefaultJobHandle() { … }
void DefaultJobHandle::Join() { … }
void DefaultJobHandle::Cancel() { … }
void DefaultJobHandle::CancelAndDetach() { … }
bool DefaultJobHandle::IsActive() { … }
void DefaultJobHandle::UpdatePriority(TaskPriority priority) { … }
}
}