Compare commits

...

14 Commits

Author SHA1 Message Date
yuk1ty ed022fc51a Capitalize the first letter in the Pinning chapter 2023-10-05 10:44:57 -07:00
Eric Holk 1ef20c71ba
Merge pull request #191 from Nereuxofficial/spawning
Added Spawning example
2023-07-06 16:36:45 -07:00
Eric Holk cdb914881e
Merge pull request #185 from rouzbehsbz/fa-IR
Add Persian/Farsi translation support
2023-07-06 16:33:40 -07:00
Bene 04e8b6c093 Added to dictionary 2023-05-05 09:13:55 +02:00
Bene d4d750523a Review Fixes. Thanks to @eholk 2023-05-05 09:11:10 +02:00
Nereuxofficial 87ac3cbdd3
Merge branch 'rust-lang:master' into spawning 2023-05-05 08:38:48 +02:00
Bene cc31e99108 Fixed Sentence about channels 2023-02-03 10:38:43 +01:00
Bene 330d3a4a85 Added JoinHandle to dictionary 2023-02-02 15:53:22 +01:00
Bene 3889ec843b JoinHandle now in Codeblock and added note about channels 2023-02-02 14:36:24 +01:00
Bene d9f4e062fa Added `` around function 2023-02-02 14:24:40 +01:00
Bene 24861ba313 Reworded a sentence 2023-02-02 14:23:55 +01:00
Bene 0f396afde7 Removed test for local testing 2023-02-02 14:16:23 +01:00
Bene 6957e04fba Added Spawning example 2023-02-02 14:12:50 +01:00
rouzbehsbz 4ae6ecf928
Add new translation
Hi I recently started to translate this book to Persian (Farsi). I would be very grateful if you add the translation.
2023-01-06 21:40:35 +03:30
8 changed files with 89 additions and 2 deletions

View File

@ -9,6 +9,7 @@ AsyncRead
AsyncWrite
AwaitingFutOne
AwaitingFutTwo
cancelling
combinator
combinators
compat
@ -37,6 +38,7 @@ interprocess
IoBlocker
IOCP
IoObject
JoinHandle
kqueue
localhost
LocalExecutor

View File

@ -0,0 +1,13 @@
[package]
name = "example_06_04_spawning"
version = "0.1.0"
edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
futures = "0.3"
[dependencies.async-std]
version = "1.12.0"
features = ["attributes"]

View File

@ -0,0 +1,46 @@
#![cfg(test)]
#![allow(dead_code)]
// ANCHOR: example
use async_std::{task, net::TcpListener, net::TcpStream};
use futures::AsyncWriteExt;
async fn process_request(stream: &mut TcpStream) -> Result<(), std::io::Error>{
stream.write_all(b"HTTP/1.1 200 OK\r\n\r\n").await?;
stream.write_all(b"Hello World").await?;
Ok(())
}
async fn main() {
let listener = TcpListener::bind("127.0.0.1:8080").await.unwrap();
loop {
// Accept a new connection
let (mut stream, _) = listener.accept().await.unwrap();
// Now process this request without blocking the main loop
task::spawn(async move {process_request(&mut stream).await});
}
}
// ANCHOR_END: example
use std::time::Duration;
async fn my_task(time: Duration) {
println!("Hello from my_task with time {:?}", time);
task::sleep(time).await;
println!("Goodbye from my_task with time {:?}", time);
}
// ANCHOR: join_all
use futures::future::join_all;
async fn task_spawner(){
let tasks = vec![
task::spawn(my_task(Duration::from_secs(1))),
task::spawn(my_task(Duration::from_secs(2))),
task::spawn(my_task(Duration::from_secs(3))),
];
// If we do not await these tasks and the function finishes, they will be dropped
join_all(tasks).await;
}
// ANCHOR_END: join_all
#[test]
fn run_task_spawner() {
futures::executor::block_on(task_spawner());
}

View File

@ -10,6 +10,7 @@ members = [
"05_02_iteration_and_concurrency",
"06_02_join",
"06_03_select",
"06_04_spawning",
"07_05_recursion",
"09_01_sync_tcp_server",
"09_02_async_tcp_server",

View File

@ -645,7 +645,7 @@ execute_unpin_future(fut); // OK
## Summary
1. If `T: Unpin` (which is the default), then `Pin<'a, T>` is entirely
equivalent to `&'a mut T`. in other words: `Unpin` means it's OK for this type
equivalent to `&'a mut T`. In other words: `Unpin` means it's OK for this type
to be moved even when pinned, so `Pin` will have no effect on such a type.
2. Getting a `&mut T` to a pinned T requires unsafe if `T: !Unpin`.

View File

@ -0,0 +1,24 @@
# `Spawning`
Spawning allows you to run a new asynchronous task in the background. This allows us to continue executing other code
while it runs.
Say we have a web server that wants to accept connections without blocking the main thread.
To achieve this, we can use the `async_std::task::spawn` function to create and run a new task that handles the
connections. This function takes a future and returns a `JoinHandle`, which can be used to wait for the result of the
task once it's completed.
```rust,edition2018
{{#include ../../examples/06_04_spawning/src/lib.rs:example}}
```
The `JoinHandle` returned by `spawn` implements the `Future` trait, so we can `.await` it to get the result of the task.
This will block the current task until the spawned task completes. If the task is not awaited, your program will
continue executing without waiting for the task, cancelling it if the function is completed before the task is finished.
```rust,edition2018
{{#include ../../examples/06_04_spawning/src/lib.rs:join_all}}
```
To communicate between the main task and the spawned task, we can use channels
provided by the async runtime used.

View File

@ -4,3 +4,4 @@ For resources in languages other than English.
- [Русский](https://doc.rust-lang.ru/async-book/)
- [Français](https://jimskapt.github.io/async-book-fr/)
- [فارسی](https://rouzbehsbz.github.io/rust-async-book/)

View File

@ -16,7 +16,7 @@
- [Executing Multiple Futures at a Time](06_multiple_futures/01_chapter.md)
- [`join!`](06_multiple_futures/02_join.md)
- [`select!`](06_multiple_futures/03_select.md)
- [TODO: Spawning]()
- [Spawning](06_multiple_futures/04_spawning.md)
- [TODO: Cancellation and Timeouts]()
- [TODO: `FuturesUnordered`]()
- [Workarounds to Know and Love](07_workarounds/01_chapter.md)