Rust adventures - Async [ Part 1 ]

栏目: IT技术 · 发布时间: 4年前

内容简介:A while ago I realized that I was a visual learner which can be frustrating at times since some concepts might take me a bit longer to fully understand until I create the proper mental image(s) for it (or somebody else does it for me).When I started wrappi

A while ago I realized that I was a visual learner which can be frustrating at times since some concepts might take me a bit longer to fully understand until I create the proper mental image(s) for it (or somebody else does it for me).

When I started wrapping my head around Async programming in Rust I felt like I was missing some of those images. What follows is my attempt visualize the concepts around async programing.

Traditional threaded applications

When creating multi-threading applications, if you wanted to execute multiple tasks at the same time you’ll need the same number of threads as tasks. So you’ll have a 1-1 mapping between tasks and threads. Let’s imagine for example, we wanted to execute 3 tasks:

use std::thread;

pub fn main() {
    thread::spawn(move || make_coffee_task());
    thread::spawn(move || waste_time_task());
    let handle = thread::spawn(move || do_laundry_task());
    // wait for other threads to complete
    handle.join().unwrap()
}

fn make_coffee_task() {
    // Mocha time!
    println!("Coffee done");
}

fn do_laundry_task() {
    // Mostly gym clothing so it should be quick!
    println!("Laundry done");
}

fn waste_time_task() {
    // Checks twitter...
    println!("Done wasting time!");
}

It might looks like this at the Operating System (OS) level:

Rust adventures - Async [ Part 1 ]

During the execution of these threads, any of them can become blocked ( unable to continue to do work ) or they could just voluntarily yield ( programmer knew the thread will have nothing to do for some time under certain condition ), at that point the OS will have to save the state of the running thread (so that it can resume running at a later point) and select another to start or continue running. This is called thread-context switch.

Rust adventures - Async [ Part 1 ]

For a variety of reasons, this context switching has some amount of overhead that penalizes performance. Additionally, the approach doesn’t scale well since the more tasks we want to run at the same time the more threads we’ll need (eventually running out of resources).

Async

With Asynchronous code instead of using one thread per tasks, we can run multiple tasks concurrently on the same OS thread.

Because multiple tasks are running on the same OS thread, the issue of thread-context switching is greatly improved (less threads to switch around). Furthermore, since we’re reusing the same OS threads for multiple tasks, we end-up using significantly less resources.

For both of those reasons our Async counterpart has the potential of being much faster:

use futures; // Using futures = "0.3.1"
use std::thread;

async fn async_main() {
    let coffee_future = make_coffee_task();
    let laundry_future = do_laundry_task();
    let waste_future = waste_time_task();

    // Running the futures concurrently within the same thread
    futures::join!(coffee_future, laundry_future, waste_future);
}

fn main() {
    futures::executor::block_on(async_main());
}

async fn make_coffee_task() {
    // Mocha time!
    println!("Using thread Id: {:?} ", thread::current().id());
    println!("Coffee done! \n");
}

async fn do_laundry_task() {
    // Mostly gym clothing so it should be quick!
    println!("Using thread Id: {:?} ", thread::current().id());
    println!("Laundry done! \n");
}

async fn waste_time_task() {
    // Checks twitter...
    println!("Using thread Id: {:?} ", thread::current().id());
    println!("Done wasting time! \n");
}

This code is meant to act cooperatively in a single thread.

Rust adventures - Async [ Part 1 ]

In the next part we’ll be exploring the Future trait and the surrounding Async programming ecosystem further.

Footnotes:


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

设计沟通十器

设计沟通十器

Daniel M. Brown / 樊旺斌 / 机械工业出版社 / 2008-12 / 49.00元

本书提供了网站设计时所需的可交付文档资料包括:概念模型,站点地图,可用性报告等,这些文档资料是设计人员和客户进行交流的主要工具。本书深入讨论了文档推介和风险规避技巧,向你展示了如何将文档资料按要求制作成有效的交流工具。 本书内容全面,结构清晰,讲解详细。可作为网站设计人员的参考用书。 关于网站设计的多数讨论好像都着眼于流程的创建,然而,要想把概念变为现实,需要一整套强大的可交付文档资料......一起来看看 《设计沟通十器》 这本书的介绍吧!

JS 压缩/解压工具
JS 压缩/解压工具

在线压缩/解压 JS 代码

URL 编码/解码
URL 编码/解码

URL 编码/解码

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具