1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35
//! xcore,is a epoll based TCP Server framework. //! # Usage //! ``` //! fn handler(fd: i32, socket: &mut TcpStream, commander: Sender<executor::Ctrl>) { //! let _ = commander; //! let _ = socket; //! let _ = fd; //! println!("Executed"); //! } //! //! fn main() { //! let listen: Listener = Listener::new("127.0.0.1:6666"); //! let worker: Executor = Executor::new(2000, handler); //! loop { //! let v = listen.get_stream(); //! match v { //! Some(v) => { //! worker.add(v); //! } //! None => {} //! } //! } //! } //! //! ``` extern crate threadpool; mod epoll_wrapper; mod core_poll; mod listener; mod executor; pub use listener::Listener; pub use executor::Executor; pub use executor::Ctrl;