reifydb-runtime 0.8.1

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 ReifyDB

//! Execution domains organized by workload shape. Long-lived actors run on the actor pool (two worker groups:
//! `coordination` for tiny high-frequency handlers, `flow` for heavy flow execution) with per-worker run queues and
//! pinned dispatch. Short-lived work (per-request actors, one-shot jobs) runs on the task pool. Data-parallel work
//! runs on the compute pool (rayon behind an install-only API). Async I/O runs on the embedded tokio runtime.
//! Native targets get the real pools; single-threaded and DST targets get the inline stub variant. The `Pools` type
//! both impls hand back is what `SharedRuntime` carries around.

#[cfg(all(not(reifydb_single_threaded), not(reifydb_target = "dst")))]
pub(crate) mod actor_pool;

#[cfg(all(not(reifydb_single_threaded), not(reifydb_target = "dst")))]
pub mod compute;

#[cfg(all(not(reifydb_single_threaded), not(reifydb_target = "dst")))]
mod native;

#[cfg(all(not(reifydb_single_threaded), not(reifydb_target = "dst")))]
pub(crate) mod task;

#[cfg(any(reifydb_single_threaded, reifydb_target = "dst"))]
mod wasm;

#[cfg(all(not(reifydb_single_threaded), not(reifydb_target = "dst")))]
pub use native::Pools;
#[cfg(any(reifydb_single_threaded, reifydb_target = "dst"))]
pub use wasm::Pools;

#[derive(Debug, Clone)]
pub struct PoolConfig {
	pub coordination_threads: usize,

	pub flow_threads: usize,

	pub task_threads: usize,

	pub compute_threads: usize,

	pub async_threads: usize,
}

impl Default for PoolConfig {
	fn default() -> Self {
		Self {
			coordination_threads: 2,
			flow_threads: 2,
			task_threads: 2,
			compute_threads: 2,
			async_threads: 1,
		}
	}
}

impl PoolConfig {
	pub fn sync_only() -> Self {
		Self {
			coordination_threads: 1,
			flow_threads: 1,
			task_threads: 1,
			compute_threads: 1,
			async_threads: 0,
		}
	}
}