Rust의 병렬 상태를 위한 Arc와 Mutex

멀티스레드 Rust 애플리케이션에서 안전한 공유 상태 접근

스레드 간 보호되지 않은 메모리 공유는 경쟁 조건을 초래하며, 동시 읽기 및 쓰기로 데이터가 손상됩니다. 동기화를 사용하더라도 데드락이 발생하여 실행 속도가 느려질 수 있습니다. 이러한 코드 디버깅은 어렵지만, Rust는 컴파일 타임에 많은 오류를 방지합니다.

카운터나 캐시와 같은 고부하 시스템에서는 적절한 동기화 기본 요소를 사용할 때 공유 접근이 정당화됩니다.

스레드 안전 데이터 공유를 위한 Arc와 Mutex

스레드 간 안전한 데이터 전송을 위해 Arc<T>와 Mutex<T>를 결합하세요. Arc<T>는 Send 및 Sync 지원과 함께 원자적 참조 카운팅을 제공하여 멀티스레드 환경에서 다중 소유권을 가능하게 합니다. Mutex<T>는 상호 배제를 보장합니다: 한 번에 하나의 스레드만 데이터에 접근합니다.

Arc는 Arc::clone을 사용하여 각 스레드에 복제되며, lock()을 통해 접근을 얻습니다. 이는 MutexGuard를 반환합니다. lock() 메서드는 중독된 뮤텍스로 패닉을 일으킬 수 있으므로, 프로덕션에서는 unwrap 대신 오류를 처리하세요.

카운터 구현 예제

use std::thread;
use std::time::Duration;
use std::sync::{Arc, Mutex};

struct Counter {
    value: i64
}

fn main() {
    let counter = Arc::new(Mutex::new(Counter {value: 0}));

    let increment = Arc::clone(&counter);
    let handler1 = thread::spawn(move || {
        for _ in 0..10 {
            let mut guard = increment.lock().unwrap();
            guard.value += 1;
            println!("inc: {}", guard.value);
            thread::sleep(Duration::from_millis(100));
        }
    });

    let reader = Arc::clone(&counter);
    let handler2 = thread::spawn(move || {
        for _ in 0..15 {
            let guard = reader.lock().unwrap();
            println!("read: {}", guard.value);
            thread::sleep(Duration::from_millis(180));
        }
    });

    handler1.join().unwrap();
    handler2.join().unwrap();

    let final_guard = counter.lock().unwrap();
    println!("final: {}", final_guard.value);
}

이 코드는 한 스레드에서 증가시키고 다른 스레드에서 읽는 것을 보여줍니다. 최종 값은 항상 10이며, 데이터 경쟁이 없습니다.

주요 스마트 포인터 비교

Rust는 메모리 관리를 위한 여러 스마트 포인터를 제공합니다. 선택은 스레드 안전성과 소유권 요구 사항에 따라 다릅니다:

• Box<T>: 힙에 단일 소유권, 크기를 알 수 없는 타입에 적합, Send + Sync 아님.
• Rc<T>: 단일 스레드 내 다중 소유권, 스레드 안전하지 않음.
• Arc<T>: 스레드 간 다중 소유권, Send + Sync, 원자적 연산으로 인한 오버헤드 있음.
• RefCell<T>: 런타임 차용 검사와 내부 가변성, 단일 스레드.
• Cell<T>: Copy 타입을 위한 경량 가변성, 패닉 없음.
• Mutex<T>: 배타적 접근을 위한 잠금, 데드락 위험 있음.
• RwLock<T>: 읽기 중심 시나리오 최적화.
• Weak<T>: Rc/Arc에서 순환 참조를 끊기 위한 약한 참조.
• ManuallyDrop<T>: 수동 소멸자 제어, 안전하지 않음.

Arc<T>는 std에서 스레드 안전 다중 소유권을 제공하는 유일한 포인터입니다.

최적화를 위한 Mutex 대안

빈번한 읽기 시나리오에서는 RwLock<T>를 고려하세요: 여러 독자가 병렬로 진행할 수 있으며, 작성자는 배타적입니다. 독자/작성자 비율 > 1일 때 성능이 더 높습니다.

락 없는 접근을 위해, 데이터가 AtomicI64와 같은 기본형이면 원자적 연산(std::sync::atomic)을 사용하세요. 이는 잠금을 완전히 피합니다.

핵심 요약

• 공유 접근은 공유 데이터가 있는 고부하 시스템에서만 정당화되며, 그렇지 않으면 소유권 이전을 선호하세요.
• 스레드 안전성을 위해 항상 Arc<T>를 Mutex<T> 또는 RwLock<T>와 결합하세요.
• lock()에서 unwrap()을 피하세요: PoisonError를 처리하세요.
• Arc<T>는 원자적 연산으로 인한 오버헤드를 가집니다—벤치마크에서 측정하세요.
• 간단한 경우에는 공유 상태 대신 채널(mpsc)을 사용하세요.

— Editorial Team