kwik 1.19.2

A set of useful tools I use for my Ph.D. research.
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
33
34
35
36
37
38

/*
 * Copyright (c) Kia Shakiba
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */

use std::{
	sync::{Arc, mpsc},
	thread,
};

use parking_lot::Mutex;

pub struct Worker {
	pub thread: Option<thread::JoinHandle<()>>,
}

pub type Job = Box<dyn 'static + FnOnce() + Send>;

impl Worker {
	pub fn new(receiver: Arc<Mutex<mpsc::Receiver<Job>>>) -> Worker {
		let thread = thread::spawn(move || {
			loop {
				let job = receiver.lock().recv();

				match job {
					Ok(job) => job(),
					Err(_) => break,
				}
			}
		});

		Worker {
			thread: Some(thread),
		}
	}
}