From 1576a62b8880113c5147602f603758b851fcab3f Mon Sep 17 00:00:00 2001 From: Harrison Date: Thu, 11 Jan 2024 11:44:59 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20REPORT-106900=E3=80=90=E8=BF=9C?= =?UTF-8?q?=E7=A8=8B=E8=AE=BE=E8=AE=A1=E6=80=A7=E8=83=BD=E3=80=91=E8=BF=9C?= =?UTF-8?q?=E7=A8=8B=E8=AE=BE=E8=AE=A1=E5=8D=8F=E8=AE=AE=E9=87=8D=E6=9E=84?= =?UTF-8?q?=20-=20=E5=B7=A5=E4=BD=9C=E7=9B=AE=E5=BD=95=E9=80=82=E9=85=8D?= =?UTF-8?q?=20RpcContext=20=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/fr/design/env/RemoteWorkspace.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/designer-base/src/main/java/com/fr/design/env/RemoteWorkspace.java b/designer-base/src/main/java/com/fr/design/env/RemoteWorkspace.java index 24b79e418c..565dd14c89 100644 --- a/designer-base/src/main/java/com/fr/design/env/RemoteWorkspace.java +++ b/designer-base/src/main/java/com/fr/design/env/RemoteWorkspace.java @@ -1,19 +1,21 @@ package com.fr.design.env; +import com.fr.base.operator.common.CommonOperator; import com.fr.cluster.engine.rpc.remote.ClusterOperator; import com.fr.design.i18n.Toolkit; -import com.fr.base.operator.common.CommonOperator; import com.fr.rpc.ExceptionHandler; import com.fr.rpc.RPCInvokerExceptionInfo; import com.fr.stable.AssistUtils; import com.fr.workspace.WorkContext; +import com.fr.workspace.WorkRpcContext; import com.fr.workspace.Workspace; import com.fr.workspace.connect.WorkspaceClient; import com.fr.workspace.connect.WorkspaceConnection; import com.fr.workspace.connect.WorkspaceConnectionInfo; -import com.fr.workspace.server.authority.decision.DecisionOperator; import com.fr.workspace.engine.rpc.WorkspaceProxyPool; import com.fr.workspace.pool.WorkObjectPool; +import com.fr.workspace.server.authority.decision.DecisionOperator; + import javax.swing.SwingWorker; /** @@ -134,7 +136,11 @@ public class RemoteWorkspace implements Workspace { @Override public void close() { + swingWorker.execute(); + + // 关闭时移除上下文 + WorkRpcContext.removeContext(client.getConnection()); } @Override