async fn run_worker( ex: &Executor, interrupt: Interrupt, queue: Queue, kill_evt: Event, queue_type: QueueType, sense_size: u32, cdb_size: u32 ) -> Result<()>