min_current_thread.rs

use actix_codec::{BytesCodec, Framed};
use futures::StreamExt;
use parking_lot::Mutex;
use std::cell::RefCell;
use std::rc::Rc;
use std::sync::Arc;
use std::time::Duration;
use tokio::net::TcpListener;
use tokio::runtime::current_thread;

fn main() {
    std::thread::spawn(|| {
        let mut crt = tokio::runtime::current_thread::Runtime::new().unwrap();
        crt.block_on(async {
            let mut listener = TcpListener::bind("127.0.0.1:8080").await.unwrap();
            loop {
                let (socket, _) = listener.accept().await.unwrap();
                current_thread::spawn(async move {
                    let framed = Framed::new(socket, BytesCodec);
                    let size: Rc<RefCell<usize>> = Rc::new(RefCell::new(0));
                    let size_mon = size.clone();
                    current_thread::spawn(async move {
                        loop {
                            tokio::timer::delay_for(Duration::from_secs(5));
                            println!("acc size: {}", size_mon.borrow());
                        }
                    });
                    framed
                        .for_each(|data| {
                            *size.borrow_mut() += i.unwrap().len();
                            futures::future::ready(())
                        })
                        .await;
                });
            }
        });
    });
    let rt = tokio::runtime::Runtime::new().unwrap();
    rt.block_on(async {
        let mut listener = TcpListener::bind("127.0.0.1:8080").await.unwrap();
        loop {
            let (socket, _) = listener.accept().await.unwrap();
            tokio::spawn(async move {
                let framed = Framed::new(socket, BytesCodec);
                let size: Arc<Mutex<usize>> = Arc::new(Mutex::new(0));
                let size_mon = size.clone();
                tokio::spawn(async move {
                    loop {
                        tokio::timer::delay_for(Duration::from_secs(5));
                        println!("acc size: {}", size_mon.lock());
                    }
                });
                framed
                    .for_each(|data| {
                        *size.lock() += i.unwrap().len();
                        futures::future::ready(())
                    })
                    .await;
            });
        }
    });
}