arty 0.4.0

Single-threaded, thread-aware application runtime.
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
31
32

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

use std::rc::Rc;

use observed::Sink;
use thread_aware::Thread;
use tick::Clock;

use crate::runtime::dispatch::DispatcherClient;
use crate::task::scheduler::Scheduler;

/// Capabilities assembled during worker initialization.
#[derive(Debug)]
#[non_exhaustive]
pub(crate) struct RuntimeBuiltins {
    pub(crate) task_scheduler: Scheduler,
    pub(crate) clock: Clock,
    pub(crate) thread: Thread,
    pub(crate) sink: Sink,
}

impl RuntimeBuiltins {
    pub(in crate::runtime) fn new(dispatcher: &Rc<DispatcherClient>, clock: Clock, thread: Thread, sink: Sink) -> Self {
        Self {
            task_scheduler: Scheduler::new(dispatcher.as_ref().clone(), thread.clone()),
            clock,
            thread,
            sink,
        }
    }
}