nndeploy.server.worker

Functions

configure_worker_logger(log_q)

  • root → QueueHandler(log_q)

ensure_picklable(obj[, default])

load_existing_plugins(plugin_dir)

malloc_trim()

poll_plugin_updates(plugin_update_q, resources)

run(task_q, result_q, progress_q, log_q, ...)

nndeploy.server.worker.malloc_trim()[源代码]
nndeploy.server.worker.configure_worker_logger(log_q)[源代码]

  • root → QueueHandler(log_q)

  • Python stdout/err → logging(print/traceback)

nndeploy.server.worker.load_existing_plugins(plugin_dir: Path)[源代码]
nndeploy.server.worker.poll_plugin_updates(plugin_update_q, resources)[源代码]
nndeploy.server.worker.ensure_picklable(obj, default=None)[源代码]
nndeploy.server.worker.run(task_q, result_q, progress_q, log_q, plugin_update_q, cancel_event_q, resources) → None[源代码]