X-Git-Url: https://piware.de/gitweb/?p=learn-rust.git;a=blobdiff_plain;f=concepts%2Fsrc%2Fmain.rs;h=3e9bbbd0cd042234615d20dd563baf6278258464;hp=06d122b9c4c727f399d8273312ffcfb2a95088fd;hb=6cf2fd87f634bb24ca0ab801a8ba3fbfff1ac418;hpb=b653e9fe9d8492f2d4b5419721f7e00b392055f9

diff --git a/concepts/src/main.rs b/concepts/src/main.rs
index 06d122b..3e9bbbd 100644
--- a/concepts/src/main.rs
+++ b/concepts/src/main.rs
@@ -4,6 +4,7 @@ mod lib;
 use std::collections::HashMap;
 use std::io::{prelude::*, ErrorKind};
 use std::fs::{self, File};
+use std::{thread, time, sync};
 
 use lib::*;
 use word_utils::{first_word, second_word};
@@ -189,6 +190,82 @@ fn test_iterators() {
     }
 }
 
+fn test_threads() {
+    let t1 = thread::spawn(|| {
+        for i in 0..10 {
+            println!("hello #{} from thread", i);
+            thread::sleep(time::Duration::from_millis(1));
+        }
+    });
+
+    for i in 1..5 {
+        println!("hello #{} from main", i);
+        thread::sleep(time::Duration::from_millis(1));
+    }
+
+    t1.join().unwrap();
+
+    // message passing
+    let (tx1, rx) = sync::mpsc::channel();
+    let tx2 = tx1.clone();
+
+    let sender1 = thread::spawn(move || {
+        for s in ["hey", "from", "sender", "one"] {
+            tx1.send(s).expect("failed to send");
+            thread::sleep(time::Duration::from_millis(100));
+        }
+    });
+
+    let sender2 = thread::spawn(move || {
+        for s in ["Servus", "von", "Produzent", "zwei"] {
+            tx2.send(s).expect("failed to send");
+            thread::sleep(time::Duration::from_millis(100));
+        }
+    });
+
+    for received in rx {
+        println!("received {} from mpsc", received);
+    }
+
+    sender1.join().unwrap();
+    sender2.join().unwrap();
+
+    // shared state
+    let counter = sync::Arc::new(sync::Mutex::new(0));
+    let mut threads = vec![];
+    for _ in 0..10 {
+        let tc = sync::Arc::clone(&counter);
+        threads.push(thread::spawn(move || {
+            *tc.lock().unwrap() += 1;
+        }));
+    }
+
+    for t in threads {
+        t.join().unwrap();
+    }
+
+    println!("counter: {}", *counter.lock().unwrap());
+}
+
+fn test_dyn_traits() {
+    let text = "I ate a salad for lunch today";
+    let mut post = Post::new();
+    post.add_text(text);
+    assert_eq!("", post.content());
+
+    post.request_review();
+    assert_eq!("", post.content());
+
+    post.reject();
+    assert_eq!("", post.content());
+
+    post.request_review();
+    assert_eq!("", post.content());
+
+    post.approve();
+    assert_eq!(text, post.content());
+}
+
 fn main() {
     test_strings();
     test_vectors();
@@ -197,4 +274,6 @@ fn main() {
     test_generics();
     test_closures();
     test_iterators();
+    test_threads();
+    test_dyn_traits();
 }