RRust By Example

intermediateConcurrency

Channel Basic

Send messages between threads with channels.

Channel Basic

Send messages between threads with channels.

Difficulty

Intermediate

Code

rust

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

fn main() {
    let (tx, rx) = mpsc::channel();

    thread::spawn(move || {
        let messages = vec!["hello", "from", "the", "thread"];
        for msg in messages {
            tx.send(msg).unwrap();
            thread::sleep(std::time::Duration::from_millis(10));
        }
    });

    for received in rx {
        println!("got: {}", received);
    }
}

Explanation

Channels enable message passing between threads.

Key Concepts

Read the code carefully and understand the data flow
Try modifying the example to see how it changes behavior
Run this code in the Rust Playground

Related Topics

Browse more examples in the concurrency category to build a complete understanding of this topic.

Common Compiler Errors in This Topic

Use these error pages as a debugging companion while practicing this example category.

cannot borrow more than once at a time

Learn what Rust error E0499 means, why it happens, and how to fix it with practical code examples.

cannot borrow as mutable because it is also borrowed as immutable

Learn what Rust error E0502 means, why it happens, and how to fix it with practical code examples.

cannot use because it was mutably borrowed

Learn what Rust error E0503 means, why it happens, and how to fix it with practical code examples.

use of moved value

Learn what Rust error E0382 means, why it happens, and how to fix it with practical code examples.

More Concurrency Examples

Arc and Mutex

Share state between threads safely with Arc<Mutex<T>>.

Atomic Types

Use atomic types for lock-free concurrent programming.

Barrier Synchronization

Synchronize multiple threads with Barrier.

RwLock

Read-write lock for concurrent reads and exclusive writes.