diff --git a/croterline/context.py b/croterline/context.py index d414841..799a1b1 100644 --- a/croterline/context.py +++ b/croterline/context.py @@ -5,6 +5,11 @@ from magicoca.chan import Chan class Context: def __init__(self): + """ + main_chan: Chan[Any] = main to sub + sub_chan: Chan[Any] = sub to main + 哪个进程发送用哪个 + """ self.main_chan: Chan[Any] = Chan[Any]() # main to sub self.sub_chan: Chan[Any] = Chan[Any]() # sub to main diff --git a/croterline/process.py b/croterline/process.py index 37d35b0..5cf6ac6 100644 --- a/croterline/process.py +++ b/croterline/process.py @@ -13,7 +13,7 @@ _current_ctx: "Context | None" = None # 注入当前进程上下文 class SubProcess: def __init__( - self, name: str, func: ProcessFuncType, ctx: Context = Context, *args, **kwargs + self, name: str, func: ProcessFuncType, ctx: Context = Context(), *args, **kwargs ): self.name = name self.func = func