Rust: thread park unpark - grizlupo/_ GitHub Wiki

이름으로도 짐작 대는 것처럼 park를 하면 스레드는 멈춘다. park는 함수다. 그런데 인수가 없다. 따라서 대상이 될 스레드를 지정할 수가 없다. 이 말은 현재 스레드가 멈춘다는 것일 테고, 이건 다시 스스로만 멈출 수 있다는 말이 된다.

반면에 unpark는 스레드의 메소드다. 그러니 스레드를 특정할 수 있다. 멈춰 있는 스레드 스스로는 아무것도 할 수 없을 테니까 다른 스레드가 unpark을 해줘야 풀린다.

park 함수 설명서에 실린 예제를 보면

use std::thread;
use std::sync::{Arc, atomic::{Ordering, AtomicBool}};
use std::time::Duration;

let flag = Arc::new(AtomicBool::new(false));
let flag2 = Arc::clone(&flag);

let parked_thread = thread::spawn(move || {
    // We want to wait until the flag is set. We *could* just spin, but using
    // park/unpark is more efficient.
    while !flag2.load(Ordering::Acquire) {
        println!("Parking thread");
        thread::park();
        // We *could* get here spuriously, i.e., way before the 10ms below are over!
        // But that is no problem, we are in a loop until the flag is set anyway.
        println!("Thread unparked");
    }
    println!("Flag received");
});

// Let some time pass for the thread to be spawned.
thread::sleep(Duration::from_millis(10));

// Set the flag, and let the thread wake up.
// There is no race condition here, if `unpark`
// happens first, `park` will return immediately.
// Hence there is no risk of a deadlock.
flag.store(true, Ordering::Release);
println!("Unpark the thread");
parked_thread.thread().unpark();

parked_thread.join().unwrap();

내용은 parked_thread라는 스레드를 만들고, 스스로 멈추면 메인 스레드가 이를 풀어주는 것이다.

좀 더 뜯어 보면

    while !flag2.load(Ordering::Acquire) {
        println!("Parking thread");
        thread::park();
        // We *could* get here spuriously, i.e., way before the 10ms below are over!
        // But that is no problem, we are in a loop until the flag is set anyway.
        println!("Thread unparked");
    }

parked_thread는 flag2가 참일 때까지 thread::park();를 반복하도록 되어 있다. flag2는 꼴랑 참/거짓 확인이 목적이지만, 두 스레드에서 공유하는 값이다 보니 AtomicBool 형이라 거창하다. atomic 연산에 주어진 Ordering에 대해서는 씹어먹는 C++ - <15 - 3. C++ memory order 와 atomic 객체> 이 설명이 C++을 기준으로 하지만 잘 되어 있다.

메인 스레드는

flag.store(true, Ordering::Release);
println!("Unpark the thread");
parked_thread.thread().unpark();

flag를 참으로 준다. flag과 flag2는 Arc로 clone된 값이기 때문에 같은 것이다. 그리고 parked_thread.thread().unpark(); 한다. parked_thread는 풀릴 것이고, flag를 이미 참으로 했기 때문에 while 문이 끝나면서 스레드도 끝날 것이다.

실행시키면

Parking thread
Unpark the thread
Thread unparked
Flag received

이렇게 된다.

예제는 flag를 참으로 주고, unpark를 하지만 만약 그냥 unpack만 한다면 parked_thread는 다시 park되면서 멈출 것이다. flag를 참으로 주기 전까지는 unpack를 해도 계속 다시 park 될 것이다.