worker_task: new_thread() - remove unused tokio channel
This commit is contained in:
parent
c5ac2b9ddd
commit
639419b049
|
@ -473,8 +473,6 @@ impl WorkerTask {
|
||||||
{
|
{
|
||||||
println!("register worker thread");
|
println!("register worker thread");
|
||||||
|
|
||||||
let (p, c) = oneshot::channel::<()>();
|
|
||||||
|
|
||||||
let worker = WorkerTask::new(worker_type, worker_id, userid, to_stdout)?;
|
let worker = WorkerTask::new(worker_type, worker_id, userid, to_stdout)?;
|
||||||
let upid_str = worker.upid.to_string();
|
let upid_str = worker.upid.to_string();
|
||||||
|
|
||||||
|
@ -495,11 +493,8 @@ impl WorkerTask {
|
||||||
};
|
};
|
||||||
|
|
||||||
worker.log_result(&result);
|
worker.log_result(&result);
|
||||||
p.send(()).unwrap();
|
|
||||||
});
|
});
|
||||||
|
|
||||||
tokio::spawn(c.map(|_| ()));
|
|
||||||
|
|
||||||
Ok(upid_str)
|
Ok(upid_str)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue