grafix_toolbox/kit/opengl/context/
offhand.rs1use super::{window::*, *};
2use crate::sync::*;
3
4pub struct Offhand<O> {
5 handle: Option<JoinHandle<()>>,
6 rx: Receiver<(O, Fence)>,
7}
8impl<O: SendStat> Offhand<O> {
9 pub fn new<I: SendStat>(w: &mut Window, depth: usize, process: impl SendStat + Fn(I) -> O) -> (Sender<I>, Self) {
10 Self::from_fn(w, depth, move |data_rx, res_sn| {
11 while let Ok(msg) = data_rx.recv() {
12 let res = process(msg);
13 res_sn.send((res, Fence::new())).warn();
14 }
15 })
16 }
17 pub fn from_fn<I: SendStat>(w: &mut Window, depth: usize, process: impl SendStat + Fn(Receiver<I>, Sender<(O, Fence)>)) -> (Sender<I>, Self) {
18 let (data_sn, data_rx) = chan::bounded::<I>(depth);
19 let (res_sn, res_rx) = chan::bounded::<(O, Fence)>(depth);
20 let handle = w.spawn_offhand_gl(move || process(data_rx, res_sn));
21 let (handle, rx) = (Some(handle), res_rx);
22 (data_sn, Self { handle, rx })
23 }
24 pub fn recv(&self) -> Option<OffhandRes<O>> {
25 self.rx.recv().ok().map(|r| OffhandRes(r))
26 }
27 pub fn try_recv(&self) -> Option<OffhandRes<O>> {
28 self.rx.try_recv().ok().map(|r| OffhandRes(r))
29 }
30}
31impl<O> Drop for Offhand<O> {
32 fn drop(&mut self) {
33 self.handle.take().valid().join().valid();
34 }
35}
36
37pub struct OffhandRes<O>((O, Fence));
38impl<O> OffhandRes<O> {
39 pub fn wait(self) -> O {
40 let (r, f) = self.0;
41 f.Block();
42 r
43 }
44}