pub struct MultiDiscreteMlpBurnPolicy<B: Backend> { /* private fields */ }Expand description
Multi-discrete MLP actor-critic policy on Burn.
Shared trunk built from the same MlpBurnConfig knobs the
single-action MlpBurnPolicy consumes, plus one Linear action
head per dimension. Per-step log-probs are summed across dims
(treating the dims as conditionally independent given the state),
and per-step entropies are averaged.
Implementations§
Source§impl<B: Backend> MultiDiscreteMlpBurnPolicy<B>
impl<B: Backend> MultiDiscreteMlpBurnPolicy<B>
Sourcepub fn new(
obs_dim: usize,
action_dims: Vec<usize>,
hidden_dim: usize,
device: &B::Device,
) -> Self
pub fn new( obs_dim: usize, action_dims: Vec<usize>, hidden_dim: usize, device: &B::Device, ) -> Self
Build a fresh multi-discrete policy with the default 2-layer
architecture (mirrors
crate::policy::multi_discrete_mlp::MultiDiscreteMlpBurnPolicy::new).
Sourcepub fn new_seeded(
obs_dim: usize,
action_dims: Vec<usize>,
hidden_dim: usize,
seed: u64,
device: &B::Device,
) -> Self
pub fn new_seeded( obs_dim: usize, action_dims: Vec<usize>, hidden_dim: usize, seed: u64, device: &B::Device, ) -> Self
Seeded variant of new: same default architecture
(orthogonal init), but constructed deterministically from seed
so two calls with the same seed produce bit-identical weights
(issue #135). Convenience wrapper for PSRO/NFSP policy factories
over the multi-discrete policy.
Sourcepub fn with_config(
obs_dim: usize,
action_dims: Vec<usize>,
config: MlpBurnConfig,
device: &B::Device,
) -> Self
pub fn with_config( obs_dim: usize, action_dims: Vec<usize>, config: MlpBurnConfig, device: &B::Device, ) -> Self
Build a fresh multi-discrete policy with custom configuration.
Sourcepub fn encoder_features(&self, obs: Tensor<B, 2>) -> Tensor<B, 2>
pub fn encoder_features(&self, obs: Tensor<B, 2>) -> Tensor<B, 2>
Shared-trunk features (mirrors
crate::policy::multi_discrete_mlp::MultiDiscreteMlpBurnPolicy::encoder_features).
Sourcepub fn forward(&self, obs: Tensor<B, 2>) -> (Vec<Tensor<B, 2>>, Tensor<B, 1>)
pub fn forward(&self, obs: Tensor<B, 2>) -> (Vec<Tensor<B, 2>>, Tensor<B, 1>)
Forward pass: per-dim action logits plus value estimate.
Returns (Vec<logits_i>, value) where
logits_i: [batch, action_dims[i]] and value: [batch].
Sourcepub fn num_action_dims(&self) -> usize
pub fn num_action_dims(&self) -> usize
Number of action dimensions (heads).
Sourcepub fn action_dim_cardinalities(&self) -> Vec<usize>
pub fn action_dim_cardinalities(&self) -> Vec<usize>
Per-dimension action cardinalities (one entry per head).
Returns the same vector that was passed to
MultiDiscreteMlpBurnPolicy::with_config /
MultiDiscreteMlpBurnPolicy::new. Reads each action head’s
weight tensor shape — Burn’s burn::nn::Linear stores weight: Param<Tensor<B, 2>> with shape [d_input, d_output], so d_output
is the per-dim cardinality. Used by the multi-agent joint trainer’s
crate::multi_agent::joint::JointPolicy::action_dims_joint impl to
size the rollout action buffer.
Sourcepub fn get_action_host(
&self,
obs: Tensor<B, 2>,
) -> (Vec<i64>, Vec<f32>, Vec<f32>)
pub fn get_action_host( &self, obs: Tensor<B, 2>, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)
Sample one action per row per dim from the per-dim categorical
distributions and return (actions_host, log_probs_host, values_host) as plain Vecs.
Thin backwards-compat wrapper around
MultiDiscreteMlpBurnPolicy::get_action_host_seeded that
constructs a thread-local RNG. Not deterministic across
calls — use
get_action_host_seeded and
pass a seeded rand::rngs::StdRng when reproducibility is
required (PSRO/NFSP/joint trainer rollouts call the seeded form
via the crate::multi_agent::joint::JointPolicy trait so that
PsroConfig::seed / NfspConfig::seed produce bit-identical
rollouts; see issue #114).
Sourcepub fn get_action_host_seeded(
&self,
obs: Tensor<B, 2>,
rng: &mut StdRng,
) -> (Vec<i64>, Vec<f32>, Vec<f32>)
pub fn get_action_host_seeded( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)
Same contract as get_action_host but
the host-side categorical draws consume rng instead of the
thread-local generator.
Mirrors crate::policy::mlp::MlpBurnPolicy::get_action_host_seeded —
the trainer-side rollout loop does not need gradient flow through
the sampled action (only the eventual
MultiDiscreteMlpBurnPolicy::evaluate_actions call on the stored
transitions matters for the PPO surrogate). We therefore do the
categorical draw on the host with rand, sidestepping Burn
0.21’s lack of a first-class multinomial op.
Layout:
actions[row * num_dims + d]is the action for dimdof rowrow. Length isbatch * num_dims.log_probs[row]is the joint log-probability summed across dims.values[row]is the value estimate.
Bit-exactness contract: two calls with the same obs, same
policy state, and same-seeded rng (StdRng::seed_from_u64)
produce element-wise identical (actions, log_probs, values).
The per-row outer loop and per-dim inner loop consume RNG draws
in a fixed row major → dim major order.
Sourcepub fn get_actions_host_seeded_batched(
&self,
obs: Tensor<B, 2>,
rng: &mut StdRng,
) -> (Vec<i64>, Vec<f32>, Vec<f32>)
pub fn get_actions_host_seeded_batched( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)
Batched seeded sampler: one forward over [N, obs_dim], then N
host-side categorical draws in row major → dim major order.
Bit-identical to calling Self::get_action_host_seeded once per row
on [1, obs_dim] slices provided the rows are drawn from the same
policy (same weights in the single batched forward, RNG consumed
one draw per dim per row, ascending). The
crate::multi_agent::joint::JointPolicy-trait batched entry point
that eliminates per-call batch-1 overhead wherever many
observations are scored through the same model in one step
(issue #235).
Sourcepub fn evaluate_actions(
&self,
obs: Tensor<B, 2>,
actions: Tensor<B, 2, Int>,
) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)
pub fn evaluate_actions( &self, obs: Tensor<B, 2>, actions: Tensor<B, 2, Int>, ) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)
Evaluate given actions: per-step summed log-prob, per-step mean entropy (across dims), and value.
§Arguments
obs-[batch, obs_dim]actions-[batch, num_dims]int (one action per dim per row)
§Returns
(log_probs [batch], entropy [batch], values [batch]).
log_probs is summed across dims; entropy is averaged across
dims (matching the tch convention so parity holds).
Trait Implementations§
Source§impl<B> AutodiffModule<B> for MultiDiscreteMlpBurnPolicy<B>
impl<B> AutodiffModule<B> for MultiDiscreteMlpBurnPolicy<B>
Source§type InnerModule = MultiDiscreteMlpBurnPolicy<<B as AutodiffBackend>::InnerBackend>
type InnerModule = MultiDiscreteMlpBurnPolicy<<B as AutodiffBackend>::InnerBackend>
Source§fn valid(&self) -> Self::InnerModule
fn valid(&self) -> Self::InnerModule
Source§fn from_inner(module: Self::InnerModule) -> Self
fn from_inner(module: Self::InnerModule) -> Self
Source§impl<B: Backend> Clone for MultiDiscreteMlpBurnPolicy<B>
impl<B: Backend> Clone for MultiDiscreteMlpBurnPolicy<B>
Source§impl<B: Backend> Display for MultiDiscreteMlpBurnPolicy<B>
impl<B: Backend> Display for MultiDiscreteMlpBurnPolicy<B>
Source§impl<B> HasAutodiffModule<B> for MultiDiscreteMlpBurnPolicy<B::InnerBackend>
impl<B> HasAutodiffModule<B> for MultiDiscreteMlpBurnPolicy<B::InnerBackend>
Source§type TrainModule = MultiDiscreteMlpBurnPolicy<B>
type TrainModule = MultiDiscreteMlpBurnPolicy<B>
Source§impl<B: AutodiffBackend> JointPolicy<B> for MultiDiscreteMlpBurnPolicy<B>where
Self: AutodiffModule<B> + Clone,
impl<B: AutodiffBackend> JointPolicy<B> for MultiDiscreteMlpBurnPolicy<B>where
Self: AutodiffModule<B> + Clone,
Source§fn get_action_host_seeded(
&self,
obs: Tensor<B, 2>,
rng: &mut StdRng,
) -> (Vec<i64>, Vec<f32>, Vec<f32>)
fn get_action_host_seeded( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)
Source§fn get_actions_host_seeded_batched(
&self,
obs: Tensor<B, 2>,
rng: &mut StdRng,
) -> (Vec<i64>, Vec<f32>, Vec<f32>)
fn get_actions_host_seeded_batched( &self, obs: Tensor<B, 2>, rng: &mut StdRng, ) -> (Vec<i64>, Vec<f32>, Vec<f32>)
obs carries N rows scored through this
one policy in a single forward, returning N actions. Read moreSource§fn evaluate_actions_joint(
&self,
obs: Tensor<B, 2>,
actions: Tensor<B, 2, Int>,
) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)
fn evaluate_actions_joint( &self, obs: Tensor<B, 2>, actions: Tensor<B, 2, Int>, ) -> (Tensor<B, 1>, Tensor<B, 1>, Tensor<B, 1>)
Source§impl<B: Backend> Module<B> for MultiDiscreteMlpBurnPolicy<B>
impl<B: Backend> Module<B> for MultiDiscreteMlpBurnPolicy<B>
Source§type Record = MultiDiscreteMlpBurnPolicyRecord<B>
type Record = MultiDiscreteMlpBurnPolicyRecord<B>
Source§fn load_record(self, record: Self::Record) -> Self
fn load_record(self, record: Self::Record) -> Self
Source§fn into_record(self) -> Self::Record
fn into_record(self) -> Self::Record
Source§fn num_params(&self) -> usize
fn num_params(&self) -> usize
Source§fn visit<Visitor: ModuleVisitor<B>>(&self, visitor: &mut Visitor)
fn visit<Visitor: ModuleVisitor<B>>(&self, visitor: &mut Visitor)
Source§fn map<Mapper: ModuleMapper<B>>(self, mapper: &mut Mapper) -> Self
fn map<Mapper: ModuleMapper<B>>(self, mapper: &mut Mapper) -> Self
Source§fn collect_devices(&self, devices: Devices<B>) -> Devices<B>
fn collect_devices(&self, devices: Devices<B>) -> Devices<B>
Source§fn to_device(self, device: &B::Device) -> Self
fn to_device(self, device: &B::Device) -> Self
Source§fn fork(self, device: &B::Device) -> Self
fn fork(self, device: &B::Device) -> Self
Source§fn devices(&self) -> Vec<<B as BackendTypes>::Device>
fn devices(&self) -> Vec<<B as BackendTypes>::Device>
Source§fn train<AB>(self) -> Self::TrainModulewhere
AB: AutodiffBackend<InnerBackend = B>,
Self: HasAutodiffModule<AB>,
fn train<AB>(self) -> Self::TrainModulewhere
AB: AutodiffBackend<InnerBackend = B>,
Self: HasAutodiffModule<AB>,
Source§fn save_file<FR, PB>(
self,
file_path: PB,
recorder: &FR,
) -> Result<(), RecorderError>
fn save_file<FR, PB>( self, file_path: PB, recorder: &FR, ) -> Result<(), RecorderError>
Source§fn load_file<FR, PB>(
self,
file_path: PB,
recorder: &FR,
device: &<B as BackendTypes>::Device,
) -> Result<Self, RecorderError>
fn load_file<FR, PB>( self, file_path: PB, recorder: &FR, device: &<B as BackendTypes>::Device, ) -> Result<Self, RecorderError>
Source§fn quantize_weights(self, quantizer: &mut Quantizer) -> Self
fn quantize_weights(self, quantizer: &mut Quantizer) -> Self
Source§impl<B: Backend> ModuleDisplay for MultiDiscreteMlpBurnPolicy<B>
impl<B: Backend> ModuleDisplay for MultiDiscreteMlpBurnPolicy<B>
Source§fn format(&self, passed_settings: DisplaySettings) -> String
fn format(&self, passed_settings: DisplaySettings) -> String
Source§fn custom_settings(&self) -> Option<DisplaySettings>
fn custom_settings(&self) -> Option<DisplaySettings>
Auto Trait Implementations§
impl<B> !Freeze for MultiDiscreteMlpBurnPolicy<B>
impl<B> !RefUnwindSafe for MultiDiscreteMlpBurnPolicy<B>
impl<B> !UnwindSafe for MultiDiscreteMlpBurnPolicy<B>
impl<B> Send for MultiDiscreteMlpBurnPolicy<B>
impl<B> Sync for MultiDiscreteMlpBurnPolicy<B>
impl<B> Unpin for MultiDiscreteMlpBurnPolicy<B>where
<B as BackendTypes>::FloatTensorPrimitive: Unpin,
<B as BackendTypes>::QuantizedTensorPrimitive: Unpin,
<B as BackendTypes>::Device: Unpin,
impl<B> UnsafeUnpin for MultiDiscreteMlpBurnPolicy<B>where
<B as BackendTypes>::Device: UnsafeUnpin,
<B as BackendTypes>::FloatTensorPrimitive: UnsafeUnpin,
<B as BackendTypes>::QuantizedTensorPrimitive: UnsafeUnpin,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more