You've already forked comprehensive-rust
mirror of
https://github.com/google/comprehensive-rust.git
synced 2025-07-07 06:55:42 +02:00
concurrency: link-checker: mentioned shared Receiver pattern
This commit is contained in:
@ -105,6 +105,7 @@ fn spawn_crawler_threads(
|
|||||||
result_sender: mpsc::Sender<CrawlResult>,
|
result_sender: mpsc::Sender<CrawlResult>,
|
||||||
thread_count: u32,
|
thread_count: u32,
|
||||||
) {
|
) {
|
||||||
|
// To multiplex the non-cloneable Receiver, wrap it in Arc<Mutex<_>>.
|
||||||
let command_receiver = Arc::new(Mutex::new(command_receiver));
|
let command_receiver = Arc::new(Mutex::new(command_receiver));
|
||||||
|
|
||||||
for _ in 0..thread_count {
|
for _ in 0..thread_count {
|
||||||
|
Reference in New Issue
Block a user