lapin 1.0.0-alpha4

AMQP client library
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

use crate::Result;
use parking_lot::Mutex;
use std::{sync::Arc, thread};

type JoinHandle = thread::JoinHandle<Result<()>>;

#[derive(Clone)]
pub(crate) struct ThreadHandle(Arc<Mutex<Option<JoinHandle>>>);

impl Default for ThreadHandle {
    fn default() -> Self {
        Self(Arc::new(Mutex::new(None)))
    }
}

impl ThreadHandle {
    pub(crate) fn register(&self, handle: JoinHandle) {
        *self.0.lock() = Some(handle);
    }

    pub(crate) fn wait(&self, context: &'static str) -> Result<()> {
        if let Some(handle) = self.0.lock().take() {
            handle.join().expect(context)?
        }
        Ok(())
    }
}