Почему привязка переменных влияет на время жизни внутри тела цикла? - PullRequest
Новая
       40

Почему привязка переменных влияет на время жизни внутри тела цикла?

0 голосов
/ 10 мая 2019

В «Языке программирования Rust» в главе 20 вы проходите упражнение по созданию простого многопоточного веб-сервера.В упражнении вы используете один канал std::sync::mpsc.Все рабочие потоки обращаются к одному Receiver, который содержится в следующем виде: Arc<Mutex<mpsc::Receiver<Message>>>.

Если мы напишем рабочий поток следующим образом: 

let thread = thread::spawn(move || loop {
    match receiver.lock().unwrap().recv().unwrap() {
        Message::NewJob(job) => {
            println!("Worker {} got a job; executing.", id);

            job.call_box();

            println!("Worker {} job complete.", id);
        }
        Message::Terminate => {
            println!("Worker {} was told to terminate.", id);

            break;
        }
    };
    println!("hello, loop");
});

Тогда мы не достигнем параллелизма, очевидно, работник удерживает блокировку мьютекса, которую я предполагал, потому что ни один работник не может выполнить другую работу до завершения предыдущей.Однако, если мы просто изменим это (как в книге показан код): 

let thread = thread::spawn(move || loop {
    let message = receiver.lock().unwrap().recv().unwrap();

    match message {
        Message::NewJob(job) => {
            println!("Worker {} got a job; executing.", id);

            job.call_box();

            println!("Worker {} job complete.", id);
        }
        Message::Terminate => {
            println!("Worker {} was told to terminate.", id);

            break;
        }
    };
    println!("hello, loop");
});

Тогда все работает нормально.Если вы запустите 5 запросов, вы увидите, что каждый поток сразу получает один.Параллелизм!

Вопрос в том, «почему привязка переменных влияет на время жизни» (полагаю, в этом причина).Или если нет, то я что-то упускаю и что это ?!Сама книга рассказывает о том, как вы не можете реализовать рабочий цикл с while let Ok(job) = receiver.lock().unwrap().recv() { из-за объема блокировки, но, очевидно, даже внутри цикла есть драконы.

1 Ответ

2 голосов
/ 10 мая 2019

Поскольку в Rust «получение ресурсов является инициализацией» .

В частности receiver.lock() возвращает тип, который получает блокировку при инициализации и освобождаетблокировка при его отбрасывании.

В вашем первом примере время жизни MutexGuard продолжается до конца оператора match, поэтому блокировка будет удерживаться, пока вызывается job.call_box(). 

match receiver.lock().unwrap().recv().unwrap() {
    // ...
};
// `MutexGuard` is dropped and lock is released here

Во втором примере защита блокировки сохраняется только достаточно долго, чтобы прочитать сообщение из вашей очереди сообщений;защитная блокировка сбрасывается в конце оператора, и блокировка снимается до ввода match. 

let message = receiver.lock().unwrap().recv().unwrap();
// `MutexGuard` is dropped and lock is released here

match message {
...