Trying to implemente channels

Author: buraksenyurt

game-engine/src/framework.rs

@@ -1,3 +1,5 @@
+use std::sync::mpsc::Sender;
+
 pub struct BotContainer {
     is_active: bool,
     bot: Box<dyn Bot>,
@@ -20,23 +22,26 @@ pub trait Actor {
     fn update(&mut self);
 }
 
-#[derive(Default)]
+// #[derive(Default)]
 #[allow(dead_code)]
 pub struct Game {
     // width: f32,
     // height: f32,
     size: Size,
     actors: Vec<Box<dyn Actor>>,
     bots_container: Vec<BotContainer>,
+    sender: Sender<String>,
 }
 
 impl Game {
-    // pub fn new() -> Self {
-    //     Game {
-    //         actors: Vec::new(),
-    //         size:Size::default()
-    //     }
-    // }
+    pub fn new(sender: Sender<String>) -> Self {
+        Game {
+            actors: Vec::new(),
+            size: Size::default(),
+            bots_container: Vec::new(),
+            sender,
+        }
+    }
     pub fn add_actor(&mut self, actor: Box<dyn Actor>) {
         self.actors.push(actor);
     }
@@ -55,6 +60,9 @@ impl Game {
     }
     pub fn apply(&self) {
         for container in &self.bots_container {
+            self.sender
+                .send("A simple message...".to_string())
+                .expect("Error in sending message into channel");
             if container.is_active {
                 container.bot.apply();
             }

game-engine/src/main.rs

@@ -1,4 +1,5 @@
 use std::{
+    sync::mpsc::channel,
     thread::{self, sleep},
     time::Duration,
 };
@@ -8,19 +9,30 @@ use framework::*;
 mod framework;
 
 fn main() {
-    // let mut game = Game::new();
-    let mut game = Game::default();
+    let (transmitter, receiver) = channel::<String>();
+
+    let mut game = Game::new(transmitter.clone());
+    // let mut game = Game::default();
     let super_mario = Player::new(1, "Super Mario".to_string());
     let mushroom = Mushroom::new(2, 10);
     game.add_actor(Box::new(super_mario));
     game.add_actor(Box::new(mushroom));
 
     let mega_mind = MindController::default();
     game.add_bot(Box::new(mega_mind));
-
     game.add_bot(Box::new(Confuser::default()));
 
+    // GameEngine::run(&game);
+
     game.apply();
+    game.draw();
+    game.update();
+
+    // drop(transmitter);
+    // Not: Sürekli dinlemede kalınacağı için loop döngüsü hiçbir zaman başlamaz.
+    for r in receiver {
+        println!("{}", r);
+    }
 
     loop {
         sleep(Duration::from_secs(2));
@@ -35,7 +47,7 @@ struct MindController {}
 
 impl Bot for MindController {
     fn apply(&self) {
-        thread::spawn(|| {
+        thread::spawn(move || {
             loop {
                 println!("\tApplying simulation...{:?}", thread::current().id());
                 sleep(Duration::from_secs(5));