nndeploy.server.task_queue

Classes

ExecutionStatus(ok[, msg, label])
TaskQueue(server, job_mp_q)	thread safe queue
TaskRecord(idx, payload, Any], state, ...)
TaskState(value[, names, module, qualname, ...])

class nndeploy.server.task_queue.ExecutionStatus(ok: bool, msg: str = '', label: str | None = None)

基类：object

__init__(ok: bool, msg: str = '', label: str | None = None)

class nndeploy.server.task_queue.TaskState(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

基类：Enum

PENDING = 1

DISPATCHED = 2

RUNNING = 3

SUCCEEDED = 4

FAILED = 5

CANCELLED = 6

class nndeploy.server.task_queue.TaskRecord(idx: int, payload: Dict[str, Any], state: nndeploy.server.task_queue.TaskState = <TaskState.PENDING: 1>, ts_submit: float = <factory>, ts_dispatch: Optional[float] = None, ts_start: Optional[float] = None, ts_finish: Optional[float] = None, worker_pid: Optional[int] = None)

基类：object

idx: int

payload: Dict[str, Any]

state: TaskState = 1

ts_submit: float

ts_dispatch: Optional[float] = None

ts_start: Optional[float] = None

ts_finish: Optional[float] = None

worker_pid: Optional[int] = None

__init__(idx: int, payload: ~typing.Dict[str, ~typing.Any], state: ~nndeploy.server.task_queue.TaskState = TaskState.PENDING, ts_submit: float = <factory>, ts_dispatch: ~typing.Optional[float] = None, ts_start: ~typing.Optional[float] = None, ts_finish: ~typing.Optional[float] = None, worker_pid: ~typing.Optional[int] = None) → None

class nndeploy.server.task_queue.TaskQueue(server: NnDeployServer, job_mp_q: mp.Queue)

基类：object

thread safe queue

__init__(server: NnDeployServer, job_mp_q: mp.Queue)

put(payload, prio: int = 0)

get(timeout: Optional[float] = None)

mark_dispatched(idx: int)

mark_started(task_id: str, worker_pid: Optional[int] = None)

task_done(idx: int, status: ExecutionStatus, results: Dict, time_profile_map: Dict)

get_current_queue()

get_history(max_items: int | None = None)

get_task_by_id(task_id: str) → Optional[dict]

clear_pending() → int

drain_job_q() → int

flush() → dict