1 files changed, 44 insertions, 0 deletions
diff --git a/engine/src/work_queue.rs b/engine/src/work_queue.rs
new file mode 100644
index 0000000..7226c7d
--- /dev/null
+++ b/engine/src/work_queue.rs
@@ -0,0 +1,44 @@
+use std::marker::PhantomData;
+use std::sync::mpsc::{channel as mpsc_channel, Sender as MpscSender};
+use std::thread::JoinHandle as ThreadHandle;
+
+pub struct Work<UserData: Send + Sync + 'static>
+{
+    pub func: fn(UserData),
+    pub user_data: UserData,
+}
+
+#[derive(Debug)]
+pub struct WorkQueue<UserData: Send + Sync + 'static>
+{
+    work_sender: MpscSender<Work<UserData>>,
+    _thread: ThreadHandle<()>,
+    _pd: PhantomData<UserData>,
+}
+
+impl<UserData: Send + Sync + 'static> WorkQueue<UserData>
+{
+    pub fn new() -> Self
+    {
+        let (work_sender, work_receiver) = mpsc_channel::<Work<UserData>>();
+
+        Self {
+            work_sender,
+            _thread: std::thread::spawn(move || {
+                let work_receiver = work_receiver;
+
+                while let Ok(work) = work_receiver.recv() {
+                    (work.func)(work.user_data);
+                }
+            }),
+            _pd: PhantomData,
+        }
+    }
+
+    pub fn add_work(&self, work: Work<UserData>)
+    {
+        if self.work_sender.send(work).is_err() {
+            tracing::error!("Cannot add work to work queue. Work queue thread is dead");
+        }
+    }
+}