diff options
| author | mo8it <mo8it@proton.me> | 2024-03-18 01:12:37 +0100 |
|---|---|---|
| committer | mo8it <mo8it@proton.me> | 2024-03-18 01:12:37 +0100 |
| commit | 71700c506c34af636fc9d4098b5bebc21dfe9a3c (patch) | |
| tree | feb04fd84e848f9926c4bae88f329b08d53286e2 /exercises/20_threads/threads3.rs | |
| parent | d8ecf4bc2d34a10149999a7974d5ba71625fab90 (diff) | |
Remove unneeded Arc
Diffstat (limited to 'exercises/20_threads/threads3.rs')
| -rw-r--r-- | exercises/20_threads/threads3.rs | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/exercises/20_threads/threads3.rs b/exercises/20_threads/threads3.rs index 91006bb..acb97b4 100644 --- a/exercises/20_threads/threads3.rs +++ b/exercises/20_threads/threads3.rs @@ -27,22 +27,18 @@ impl Queue { } fn send_tx(q: Queue, tx: mpsc::Sender<u32>) -> () { - let qc = Arc::new(q); - let qc1 = Arc::clone(&qc); - let qc2 = Arc::clone(&qc); - thread::spawn(move || { - for val in &qc1.first_half { + for val in q.first_half { println!("sending {:?}", val); - tx.send(*val).unwrap(); + tx.send(val).unwrap(); thread::sleep(Duration::from_secs(1)); } }); thread::spawn(move || { - for val in &qc2.second_half { + for val in q.second_half { println!("sending {:?}", val); - tx.send(*val).unwrap(); + tx.send(val).unwrap(); thread::sleep(Duration::from_secs(1)); } }); |
