Chronaxis用户手册English
本页目录相关类型对象导航worker_main参数返回说明异常说明

chronaxis.fast.session_worker

可复用文件worker:流式求贡献,获得父进程许可后直传或直接写暂存。

控制和数据独立,任一时刻只有一个尚未交付块。worker不累计总量、不创建 子进程;EOF包含最终块数与已成功关闭的文件事实。父进程拥有取消和回收责任。

这是模块参考。日常调用先查公开API索引;下划线对象和嵌套函数供维护者查阅。签名来自固定源码,公开类构造签名经实际Python接口核对。

相关类型

ControlChannel、Path

对象导航

对象 用途
worker_main 运行父授权的文件任务。
导入与重导出来源(展开)
python
from hashlib import sha256
from pathlib import Path
from time import perf_counter
from .._control_wire import ControlChannel
from .blocks import batches, encode, LIMIT
from ..dbc_loading import load_dbc_file

worker_main

运行父授权的文件任务。

python
worker_main(control, data, cancel)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
control multiprocessing.connection.Connection 是 无 位置或关键字。双向控制连接,传递文件任务、交付许可、错误及最终计数;与完整数据传输分离。
data multiprocessing.connection.Connection 是 无 位置或关键字。单向数据连接,传递获准直传的完整贡献块;暂存块只通过控制连接通知位置。
cancel Event | None 是 无 位置或关键字。调用方取消事件;is_set为真时停止继续读取或调度,None表示没有外部取消信号。

返回说明

None。

异常说明

原错误通过控制通道报告;断管退出,finally释放读取器。

源码:src/chronaxis/fast/session_worker.py:17(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

Chronaxis 用户手册 · 离线阅读