Struct ThreadManager 

pub struct ThreadManager { /* private fields */ }

ThreadManager is responsible for creating threads and maintaining them in memory.

Implementations

impl ThreadManager

pub fn new( config: &Config, auth_manager: Arc<AuthManager>, models_manager: SharedModelsManager, codex_apps_tools_cache: CodexAppsToolsCache, session_source: SessionSource, environment_manager: Arc<EnvironmentManager>, extensions: Arc<ExtensionRegistry<Config>>, user_instructions_provider: Arc<dyn UserInstructionsProvider>, analytics_events_client: Option<AnalyticsEventsClient>, thread_store: Arc<dyn ThreadStore>, agent_graph_store: Option<Arc<dyn AgentGraphStore>>, installation_id: String, attestation_provider: Option<Arc<dyn AttestationProvider>>, external_time_provider: Option<Arc<dyn TimeProvider>>, ) -> Self

pub fn session_source(&self) -> SessionSource

pub fn auth_manager(&self) -> Arc<AuthManager>

pub fn skills_service(&self) -> Arc<SkillsService>

pub fn plugins_manager(&self) -> Arc<PluginsManager>

pub fn mcp_manager(&self) -> Arc<McpManager>

pub fn environment_manager(&self) -> Arc<EnvironmentManager>

pub fn default_environment_selections( &self, cwd: &AbsolutePathBuf, workspace_roots: &[AbsolutePathBuf], ) -> Vec<TurnEnvironmentSelection>

pub fn validate_environment_selections( &self, environments: &[TurnEnvironmentSelection], ) -> CodexResult<()>

pub fn get_models_manager(&self) -> SharedModelsManager

pub async fn list_models( &self, refresh_strategy: RefreshStrategy, http_client_factory: HttpClientFactory, ) -> Vec<ModelPreset>

pub fn list_collaboration_modes(&self) -> Vec<CollaborationModeMask>

pub async fn list_thread_ids(&self) -> Vec<ThreadId>

pub fn subscribe_thread_created(&self) -> Receiver<ThreadId>

pub async fn get_thread( &self, thread_id: ThreadId, ) -> CodexResult<Arc<CodexThread>>

pub async fn update_thread_metadata( &self, thread_id: ThreadId, patch: ThreadMetadataPatch, include_archived: bool, ) -> CodexResult<StoredThread>

Updates metadata for loaded and cold threads through one entrypoint.

Loaded threads route through CodexThread/LiveThread, so metadata changes stay ordered with live rollout writes. Cold threads go directly to the store, which owns unloaded JSONL compatibility and SQLite metadata updates.

pub async fn list_agent_subtree_thread_ids( &self, thread_id: ThreadId, ) -> CodexResult<Vec<ThreadId>>

List thread_id plus all known descendants in its spawn subtree.

pub async fn start_thread(&self, config: Config) -> CodexResult<NewThread>

pub async fn start_thread_with_tools( &self, config: Config, dynamic_tools: Vec<DynamicToolSpec>, ) -> CodexResult<NewThread>

pub async fn start_thread_with_options( &self, options: StartThreadOptions, ) -> CodexResult<NewThread>

pub async fn spawn_subagent( &self, forked_from_thread_id: ThreadId, options: StartThreadOptions, ) -> CodexResult<NewThread>

Spawn a subagent by forking persisted history from forked_from_thread_id.

pub async fn resume_thread_from_rollout( &self, config: Config, rollout_path: PathBuf, auth_manager: Arc<AuthManager>, parent_trace: Option<W3cTraceContext>, supports_openai_form_elicitation: bool, ) -> CodexResult<NewThread>

pub async fn resume_thread_with_history( &self, config: Config, initial_history: InitialHistory, auth_manager: Arc<AuthManager>, parent_trace: Option<W3cTraceContext>, supports_openai_form_elicitation: bool, ) -> CodexResult<NewThread>

pub async fn remove_thread( &self, thread_id: &ThreadId, ) -> Option<Arc<CodexThread>>

Removes the thread from the manager’s internal map, though the thread is stored as Arc<CodexThread>, it is possible that other references to it exist elsewhere. Returns the thread if the thread was found and removed.

pub async fn shutdown_all_threads_bounded( &self, timeout: Duration, ) -> ThreadShutdownReport

Tries to shut down all tracked threads concurrently within the provided timeout. Threads that complete shutdown are removed from the manager; incomplete shutdowns remain tracked so callers can retry or inspect them later.

pub async fn fork_thread<S>( &self, snapshot: S, config: Config, path: PathBuf, thread_source: Option<ThreadSource>, parent_trace: Option<W3cTraceContext>, ) -> CodexResult<NewThread>

where S: Into<ForkSnapshot>,

Fork an existing thread by snapshotting rollout history according to snapshot and starting a new thread with identical configuration (unless overridden by the caller’s config). The new thread will have a fresh id.

pub async fn fork_thread_from_history<S>( &self, snapshot: S, config: Config, history: InitialHistory, thread_source: Option<ThreadSource>, parent_trace: Option<W3cTraceContext>, supports_openai_form_elicitation: bool, ) -> CodexResult<NewThread>

where S: Into<ForkSnapshot>,

Fork an existing thread from already-loaded store history.