类class io.agentscope.builder.web.coord 2.x

TurnLeaseService

@Service public class TurnLeaseService

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:41–231

轮次 Lease 服务，承载智能体的部署、调度与服务化运行。位于 io.agentscope.builder.web.coord 包。核心成员包括 acquireOrConflict、acquireOrConflictFenced、currentLease、localInstanceId、TurnLeaseService。

Acquires and heartbeats the in-flight turn lease for a managed session. Does not sticky-route sessions — only mutexes concurrent turn execution across Brain replicas. Heartbeats also consume cross-replica interrupt tickets from CoordinationStore.

嵌套类摘要Nested Class Summary

类Class	类型Kind	说明Description
`TurnLease`	类class	轮次 Lease，承载智能体的部署、调度与服务化运行。 A class in io.agentscope.builder.web.coord that deploys, schedules and serves agents.

构造器摘要Constructor Summary

构造器Constructor	说明Description
`public` `TurnLeaseService(CoordinationStore coordinationStore, BuilderInstanceId instanceId, long ttlSeconds)`	初始化 `TurnLeaseService` 实例。 Creates a new instance.

方法摘要Method Summary

方法Method	说明Description
`public` `TurnLease acquireOrConflict(String sessionId, String ownerId, Runnable onRemoteInterrupt)`	执行 `acquireOrConflict` 方法。 Tries to acquire the turn lease.
`public` `TurnLease acquireOrConflictFenced(String sessionId, String ownerId, Consumer<CoordinationStore.TurnInterruptRequest> onRemoteInterrupt)`	执行 `acquireOrConflictFenced` 方法。 Acquires a turn lease whose interrupt callback receives the durable request fence.
`public` `TurnLease acquireOrConflict(String sessionId, String ownerId)` deprecated	执行 `acquireOrConflict` 方法。 Performs the acquire or conflict operation.
`public Optional<CoordinationStore.LeaseHandle> currentLease(String sessionId)`	设置该参数。 Performs the current lease operation.
`public String localInstanceId()`	返回本地实例标识。 Returns the local instance id.

构造器详情Constructor Detail

TurnLeaseService

public TurnLeaseService(CoordinationStore coordinationStore, BuilderInstanceId instanceId, long ttlSeconds)

初始化 TurnLeaseService 实例。

Creates a new instance.

参数Parameters

名称Name	类型Type	说明Description
`coordinationStore`	CoordinationStore	coordination 存储（类型 `CoordinationStore`）。The coordination store.
`instanceId`	BuilderInstanceId	实例标识（类型 `BuilderInstanceId`）。The instance id.
`ttlSeconds`	long	存活时间秒（类型 `long`）。The ttl seconds.

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:57–63

方法详情Method Detail

acquireOrConflict

public TurnLease acquireOrConflict(String sessionId, String ownerId, Runnable onRemoteInterrupt)

执行 acquireOrConflict 方法。

Tries to acquire the turn lease.

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.
`ownerId`	String	所有者标识（类型 `String`）。The owner id.
`onRemoteInterrupt`	Runnable	on 远程中断（类型 `Runnable`）。invoked when another plane requests interrupt via the coordination store (may be called from the heartbeat thread)

返回Returns TurnLease

返回TurnLease。a handle that must be `TurnLease#close()`-d (releases lease + stops heartbeat)

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:79–89

acquireOrConflictFenced

public TurnLease acquireOrConflictFenced(String sessionId, String ownerId, Consumer<CoordinationStore.TurnInterruptRequest> onRemoteInterrupt)

执行 acquireOrConflictFenced 方法。

Acquires a turn lease whose interrupt callback receives the durable request fence.

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.
`ownerId`	String	所有者标识（类型 `String`）。The owner id.
`onRemoteInterrupt`	Consumer<CoordinationStore.TurnInterruptRequest>	on 远程中断（类型 `Consumer`）。The on remote interrupt.

返回Returns TurnLease

返回TurnLease。Returns turn lease.

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:92–174

acquireOrConflict

public TurnLease acquireOrConflict(String sessionId, String ownerId)

deprecated

执行 acquireOrConflict 方法。

Performs the acquire or conflict operation.

已弃用。Deprecated. 已弃用，请改用受支持的替代 API。use `#acquireOrConflict(String, String, Runnable)`

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.
`ownerId`	String	所有者标识（类型 `String`）。The owner id.

返回Returns TurnLease

返回TurnLease。Returns turn lease.

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:177–179

currentLease

public Optional<CoordinationStore.LeaseHandle> currentLease(String sessionId)

设置该参数。

Performs the current lease operation.

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.

返回Returns Optional<CoordinationStore.LeaseHandle>

返回可选。Returns optional.

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:181–183

localInstanceId

public String localInstanceId()

返回本地实例标识。

Returns the local instance id.

返回Returns String

返回字符串结果。Returns a string.

源码Source io/agentscope/builder/web/coord/TurnLeaseService.java:185–187

嵌套类详情Nested Class Detail

TurnLease

public final class TurnLease implements AutoCloseable

轮次 Lease，承载智能体的部署、调度与服务化运行。位于 io.agentscope.builder.web.coord 包，实现 AutoCloseable。核心成员包括 sessionId、instanceId、coordinationId、close。

A class in io.agentscope.builder.web.coord that deploys, schedules and serves agents. Declared in io.agentscope.builder.web.coord. Implements AutoCloseable.