#include <handy/handy.h>
using namespace handy;

int main(int argc, const char* argv[]) {
    EventBase base;
    Signal::signal(SIGINT, [&]{ base.exit(); });
    TcpServerPtr svr = TcpServer::startServer(&base, "", 99);
    exitif(svr == NULL, "start tcp server failed");
    TcpConnPtr con = TcpConn::createConnection(&base, "localhost", 99);
    std::thread th([con,&base](){
        sleep(1);
        info("thread want to close an connection");
        base.safeCall([con](){ con->close(); }); //其他线程需要操作连接，应当通过safeCall把操作交给io线程来做
    });
    base.runAfter(1500, [&base](){base.exit();});
    base.loop();
    th.join();
}