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