Rust——并发/并行

1.并发和并行理解

　　比如老师布置了10个不同的任务，小明一个人依次处理这10个任务；另外一种是小明和同学校花一起依次各处理5个任务。第一种处理方式就是我们理解的并发处理，第二种就是我们理解的并行处理。假设小明/小花的处理能力完全一致，明显第二种方式的处理效率为第一种处理方式的两倍

并发处理和并行处理都是对“多任务”进行处理，并发是轮流处理，并行是同时处理

a.并发处理

　　并发处理关键：快速轮换处理不同的任务，给人以所有任务同时在运行的假象

　　并发系统支持2个及以上多个线程的同时存在，但是多个线程之间要轮流运行

b.并行处理

　　并行系统支持2个及以上多个线程的同时运行，系统中的每个线程都单独分配到一个独立的处理器核上

2.线程

　　Rust中通过std::thread::spawn函数创建新线程

fn spawn_f(){
    for i in 0..5{
        println!("spawned thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
}

fn main() {
    thread::spawn(spawn_f);

    for i in 0..5{
        println!("main thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
    
}

　　输出结果：

 　　若程序更改如下：

fn spawn_f(){
    for i in 0..5{
        println!("spawned thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
}

fn main() {
    thread::spawn(spawn_f);

    for i in 0..4{    //更改此处
        println!("main thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
    
}

　　输出结果如下：

　　从以上程序可以看出，主程序结束后，线程也结束运行，没有输出打印5次

　　若要实现子线程完全打印，我们可以使用Join方法，代码更改如下：

fn spawn_f(){
    for i in 0..5{
        println!("spawned thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
}

fn main() {
    let handle = thread::spawn(spawn_f);

    for i in 0..3{
        println!("main thread print {}",i);
        thread::sleep(Duration::from_millis(1));
    }
    handle.join().unwrap();
}

　　运行后结果如下：

　　join方法使子线程运行结束后再停止运行程序