byteflow-actors 0.8.0

Embeddable flow runtime: M:N scheduler, Atomic Hop (Message+Cap), supervisor — use byteflow::
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Optional JIT hook for worker threads (`feature = "jit"`).

use std::sync::Arc;

use crate::jit::{run_vm_with_jit_runtime, JitRuntime};
use crate::vm::VmResult;

use super::process::Flow;
use super::runtime::Shared;

/// Run one scheduling quantum, using the shared JIT runtime when enabled.
pub fn run_flow_quantum(flow: &mut Flow, shared: &Shared) -> VmResult {
    let Some(jit) = shared.jit.as_ref() else {
        return flow.vm.run(shared.quantum);
    };
    run_vm_with_jit_runtime(
        &mut flow.vm,
        shared.quantum,
        jit,
        Some(&shared.metrics),
    )
}

/// Construct the runtime-wide JIT state when enabled in config.
pub fn new_runtime(
    chunk: Arc<crate::Chunk>,
    hot_threshold: u32,
) -> Arc<JitRuntime> {
    Arc::new(JitRuntime::new(chunk, hot_threshold))
}