fn launch(&self) {
        let mut threads = Vec::<ThreadData>::new();
        for _ in 0 .. self.worker_count {
            let (worker, thread_data) = self.new_worker();
            self.workers.write().insert(worker.id, worker);
            threads.push(thread_data);
        }
        for thread in threads {
            let id = thread.id;
            self.workers.write().get_mut(&id).unwrap().thread = thread.spawn();
        }
    }
// lauch the workers and get the executors running
lauch the workers and get the executors running
lauch the workers and get the executors running
fn launch(&self) {
        let mut threads = Vec::<ThreadData>::new();
        for _ in 0 .. self.worker_count {
            let (worker, thread_data) = self.new_worker();
            self.workers.write().insert(worker.id, worker);
            threads.push(thread_data);
        }
        for thread in threads {
            let id = thread.id;
            self.workers.write().get_mut(&id).unwrap().thread = thread.spawn();
        }
    }
fn launch ( & self ) { let mut threads = Vec :: < ThreadData > :: new ( ) ; for _ in 0 .. self . worker_count { let ( worker , thread_data ) = self . new_worker ( ) ; self . workers . write ( ) . insert ( worker . id , worker ) ; threads . push ( thread_data ) ; } for thread in threads { let id = thread . id ; self . workers . write ( ) . get_mut ( & id ) . unwrap ( ) . thread = thread . spawn ( ) ; } }
lauch the workers and get the executors running
lauch the workers and get the executors running
&self