hatter/simple-rust-tests
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

chore:rename

Browse Source
This commit is contained in:
Hatter Jiang
2022-03-19 23:17:40 +08:00
parent 87f21a0b93
commit effb8587b1
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
__concurrent/async_study/src/main.rs
View File

@@ -30,27 +30,27 @@ async fn main() {
for _ in 0..3 { for _ in 0..3 {
let new_stream_id = stream_id.fetch_add(1, Ordering::SeqCst); let new_stream_id = stream_id.fetch_add(1, Ordering::SeqCst);
let left_stream = create_stream(new_stream_id, right_to_left_sender.clone(), right_consumer_stream_map.clone()); let right_stream = create_stream(new_stream_id, right_to_left_sender.clone(), right_consumer_stream_map.clone());
let right_stream = create_stream(new_stream_id, left_to_right_sender.clone(), left_consumer_stream_map.clone()); let left_stream = create_stream(new_stream_id, left_to_right_sender.clone(), left_consumer_stream_map.clone());
let (left_stream_reader, mut left_stream_writer) = tokio::io::split(left_stream);
let (right_stream_reader, mut right_stream_writer) = tokio::io::split(right_stream); let (right_stream_reader, mut right_stream_writer) = tokio::io::split(right_stream);
let (left_stream_reader, mut left_stream_writer) = tokio::io::split(left_stream);
let a = loop_read(left_stream_reader, format!("#{} left reader", new_stream_id)); let a = loop_read(right_stream_reader, format!("#{} right reader", new_stream_id));
let b = loop_read(right_stream_reader, format!("#{} right reader", new_stream_id)); let b = loop_read(left_stream_reader, format!("#{} left reader", new_stream_id));
let c = tokio::spawn(async move { let c = tokio::spawn(async move {
for i in 0..3 { for i in 0..3 {
sleep(Duration::from_millis(100)).await; sleep(Duration::from_millis(100)).await;
let _ = left_stream_writer.write_all(format!("Left message: {} - {}", new_stream_id, i).as_bytes()).await; let _ = right_stream_writer.write_all(format!("Right send message: {} - {}", new_stream_id, i).as_bytes()).await;
} }
let _ = left_stream_writer.shutdown().await; let _ = right_stream_writer.shutdown().await;
}); });
let d = tokio::spawn(async move { let d = tokio::spawn(async move {
for i in 0..3 { for i in 0..3 {
sleep(Duration::from_millis(100)).await; sleep(Duration::from_millis(100)).await;
let _ = right_stream_writer.write_all(format!("Right message: {} - {}", new_stream_id, i).as_bytes()).await; let _ = left_stream_writer.write_all(format!("Left send message: {} - {}", new_stream_id, i).as_bytes()).await;
} }
let _ = right_stream_writer.shutdown().await; let _ = left_stream_writer.shutdown().await;
}); });
joins.extend([a, b, c, d]); joins.extend([a, b, c, d]);