diff --git a/src/queue.rs b/src/queue.rs deleted file mode 100644 index fbb80f9..0000000 --- a/src/queue.rs +++ /dev/null @@ -1,7 +0,0 @@ -pub trait JobQueue { - type Job; - type Error; - - fn push(job: Self::Job) -> Result<(), Self::Error>; - fn pop(job: Self::Job) -> Result<(), Self::Error>; -} diff --git a/src/worker_pool.rs b/src/worker_pool.rs index b7245ec..a9d7d3d 100644 --- a/src/worker_pool.rs +++ b/src/worker_pool.rs @@ -35,7 +35,7 @@ impl WorkerThread { } pub fn spawn_in_pool(name: String, restarts: u64) { - let mut builder = thread::Builder::new().name(name.clone()); + let builder = thread::Builder::new().name(name.clone()); info!( "starting a worker thread {}, number of restarts {}",