类class io.agentscope.core.training.runner 2.x

TaskExecutionRegistry

public class TaskExecutionRegistry

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:68–279

任务执行注册表，对智能体行为进行评测、追踪与可观测性分析。位于 io.agentscope.core.training.runner 包。核心成员包括 register、getRunsByTask、getRun、getAllTaskIds、getRunCount、getTaskCount。

Task Execution Registry

Stores execution contexts for all Runs of all Tasks, supports querying and analysis.

Core features:

Register RunExecutionContext for each Run
Query all Runs for a Task
Query specific (Task, Run)
Statistical analysis (total Task count, total Run count, etc.)

Data structure:


Map&lt;String, List&lt;RunExecutionContext&gt;&gt;
├─ "task-001" → [ctx(run=0), ctx(run=1), ctx(run=2)]
├─ "task-002" → [ctx(run=0), ctx(run=1)]
└─ "task-003" → [ctx(run=0)]

Thread safety:

Uses ConcurrentHashMap for storage
List uses synchronized wrapper
Supports concurrent read/write

Memory management:

Provides manual cleanup interface #cleanup(String)
Provides clear all data interface #clearAll()
Recommendation: Periodically clean up expired data to avoid memory leaks

嵌套类摘要Nested Class Summary

类Class	类型Kind	说明Description
`RegistryStats`	类class	注册表 Stats，对智能体行为进行评测、追踪与可观测性分析。 Statistical information

方法摘要Method Summary

方法Method	说明Description
`public static void register(RunExecutionContext context)` static	设置注册。 Register a RunExecutionContext
`public static List<RunExecutionContext> getRunsByTask(String taskId)` static	获取 `getRunsByTask`。 Get contexts for all Runs of specified Task
`public static` `RunExecutionContext getRun(String taskId, String runId)` static	获取运行。 Get context for specified (Task, Run)
`public static Set<String> getAllTaskIds()` static	获取所有任务 IDs。 Get all Task IDs
`public static int getRunCount(String taskId)` static	获取运行数量。 Get Run count for specified Task
`public static int getTaskCount()` static	获取总数任务数量。 Get total Task count
`public static int getTotalRunCount()` static	获取总数运行数量。 Get total Run count (all Runs of all Tasks)
`public static int cleanup(String taskId)` static	设置该参数。 Clean up all data for specified Task
`public static void clearAll()` static	清空所有。 Clear all data
`public static` `RegistryStats getStats()` static	获取 `getStats`。 Get statistical summary

方法详情Method Detail

register

public static void register(RunExecutionContext context)

static

设置注册。

参数Parameters

名称Name	类型Type	说明Description
`context`	RunExecutionContext	上下文（类型 `RunExecutionContext`）。Run execution context

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:88–110

getRunsByTask

public static List<RunExecutionContext> getRunsByTask(String taskId)

static

获取 getRunsByTask。

Get contexts for all Runs of specified Task Return value: Copy of list sorted by Run ID in ascending order.

参数Parameters

名称Name	类型Type	说明Description
`taskId`	String	任务标识（类型 `String`）。Task ID

返回Returns List<RunExecutionContext>

返回列出。All Run contexts for this Task (returns empty list if Task doesn't exist)

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:120–136

getRun

public static RunExecutionContext getRun(String taskId, String runId)

static

获取运行。

Get context for specified (Task, Run)

参数Parameters

名称Name	类型Type	说明Description
`taskId`	String	任务标识（类型 `String`）。Task ID
`runId`	String	运行标识（类型 `String`）。Run ID

返回Returns RunExecutionContext

返回RunExecutionContext。Corresponding context, returns null if not found

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:145–161

getAllTaskIds

public static Set<String> getAllTaskIds()

static

获取所有任务 IDs。

Get all Task IDs

返回Returns Set<String>

设置的所有任务 IDs。Set of all Task IDs

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:168–170

getRunCount

public static int getRunCount(String taskId)

static

获取运行数量。

Get Run count for specified Task

参数Parameters

名称Name	类型Type	说明Description
`taskId`	String	任务标识（类型 `String`）。Task ID

返回Returns int

返回数值结果。Run count (returns 0 if Task doesn't exist)

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:178–184

getTaskCount

public static int getTaskCount()

static

获取总数任务数量。

Get total Task count

返回Returns int

返回数值结果。Task count

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:191–193

getTotalRunCount

public static int getTotalRunCount()

static

获取总数运行数量。

Get total Run count (all Runs of all Tasks)

返回Returns int

返回数值结果。Total Run count

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:200–202

cleanup

public static int cleanup(String taskId)

static

设置该参数。

Clean up all data for specified Task Used to release memory and avoid memory leaks from long-running processes.

参数Parameters

名称Name	类型Type	说明Description
`taskId`	String	任务标识（类型 `String`）。Task ID

返回Returns int

返回数值结果。Number of Runs cleaned up

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:212–225

clearAll

public static void clearAll()

static

清空所有。

Clear all data Warning: This operation deletes all Run data for all Tasks, use with caution!

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:232–237

getStats

public static RegistryStats getStats()

static

获取 getStats。

Get statistical summary

返回Returns RegistryStats

返回RegistryStats。Statistical information

源码Source io/agentscope/core/training/runner/TaskExecutionRegistry.java:244–246

嵌套类详情Nested Class Detail

RegistryStats

public static class RegistryStats

注册表 Stats，对智能体行为进行评测、追踪与可观测性分析。位于 io.agentscope.core.training.runner 包。核心成员包括 getTaskCount、getTotalRunCount、getAverageRunsPerTask、toString。

Statistical information