From 280ab5e6be3fa14815149f080bcd8b3ee6d80c82 Mon Sep 17 00:00:00 2001 From: laolq Date: Fri, 18 Jul 2025 16:34:26 +0800 Subject: [PATCH] =?UTF-8?q?actor=E7=BB=93=E6=9E=84=E4=BD=93=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E8=8E=B7=E5=BE=97=20processor=20=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/node/actor.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/cluster/node/actor.go b/cluster/node/actor.go index 4d3eae66..a636b8c3 100644 --- a/cluster/node/actor.go +++ b/cluster/node/actor.go @@ -54,6 +54,11 @@ func (a *Actor) Proxy() *Proxy { return a.scheduler.node.proxy } +// Processor 获取处理器 +func (a *Actor) Processor() Processor { + return a.processor +} + // Invoke 调用函数（Actor内线程安全） func (a *Actor) Invoke(fn func()) { a.rw.RLock()