[RUST/COMMON] spawn 함수 : 쓰레드로 병렬 계산 처리하기

■ spawn 함수를 사용해 쓰레드로 병렬 계산을 처리하는 방법을 보여준다.

 

▶ 예제 코드 (RS)

use std::sync::mpsc;
use std::thread;
use std::time;

fn main()
{
    let index_array : [i64; 7] = [43, 42, 20, 39, 37, 35, 30];

    let instant : time::Instant = time::Instant::now();

    let (tx, rx) = mpsc::channel::<(i64, i64)>();

    for index in index_array
    {
        let sender : mpsc::Sender<(i64, i64)> = tx.clone();

        thread::spawn
        (
            move ||
            {
                let fibonacci_sequence : i64 = calculate_fibonacci_sequence(index);

                sender.send((index, fibonacci_sequence)).unwrap();
            }
        );
    }

    let mut job_count : usize = index_array.len();

    loop
    {
        if let Ok((index, fibonacci_sequence)) = rx.recv()
        {
            job_count -= 1;

            println!("[결과] (남은 계산 : {}) {} 번째 피보나치 수 : {} ", job_count, index, fibonacci_sequence);

            if job_count <= 0
            {
                let duration : time::Duration = instant.elapsed();

                println!("실행 시간 : {:?}", duration);

                break;
            }
        }

        thread::sleep(time::Duration::from_millis(300));
    }
}

fn calculate_fibonacci_sequence(index : i64) -> i64
{
    if index == 1
    {
        return 0;
    }

    if index == 2
    {
        return 1;
    }

    return calculate_fibonacci_sequence(index - 2) + calculate_fibonacci_sequence(index - 1);
}