tin-project 介绍
tin 项目是完整实现的 C 版 go 语言运行时。它参考 go 语言运行时,将 go 语言运行时用 C 重写了一遍, 让你可以在 C++ 中使用
go 的风格写程序。
平台
-
Windows XP or later
-
OS X 10.8 or later
-
Linux 2.6.23 or later
构建
-
git clone –recursive https://github.com/cloudpeak/tin.git
-
mkdir build
-
cd build
-
Visual Studio 2015 Win64
- cmake -G “Visual Studio 14 2015 Win64” ../tin -DCMAKE_BUILD_TYPE=RELEASE
-
Visual Studio 2015 Win32
- cmake -G “Visual Studio 14 2015” ../tin -DCMAKE_BUILD_TYPE=RELEASE
-
Visual Studio 2008 Win32
- cmake -G “Visual Studio 9 2008” ../tin -DCMAKE_BUILD_TYPE=RELEASE
-
GCC or Clang
- cmake ../tin -DCMAKE_BUILD_TYPE=RELEASE && make
示例
#include "tin/all.h" void HandleClient(tin::net::TcpConn conn) { // Set TCP Read Write buffer. conn->SetReadBuffer(64 * 1024); conn->SetWriteBuffer(64 * 1024); // user space buffer size. const int kIOBufferSize = 4 * 1024; scoped_ptr<char[]> buf(new char[kIOBufferSize]); // set read, write deadline. const int64 kRWDeadline = 20 * tin::kSecond; conn->SetDeadline(kRWDeadline); while (true) { int n = conn->Read(buf.get(), kIOBufferSize); int err = tin::GetErrorCode(); if (n > 0) { conn->SetReadDeadline(kRWDeadline); } if (err != 0) { VLOG(1) << "Read failed due to: " << tin::GetErrorStr(); // FIN received, graceful close, we can still send. if (err == TIN_EOF) { if (n > 0) { conn->Write(buf.get(), n); } conn->CloseWrite(); // delay a while to avoid RST. tin::NanoSleep(500 * tin::kMillisecond); } break; } DCHECK_GT(n, 0); conn->Write(buf.get(), n); if (tin::GetErrorCode() != 0) { VLOG(1) << "Write failed due to " << tin::GetErrorStr(); break; } conn->SetWriteDeadline(kRWDeadline); } conn->Close(); } int TinMain(int argc, char** argv) { const uint16 kPort = 2222; bool use_ipv6 = false; tin::net::TCPListener listener = tin::net::ListenTcp(use_ipv6 ? "0:0:0:0:0:0:0:0" : "0.0.0.0", kPort); if (tin::GetErrorCode() != 0) { LOG(FATAL) << "Listen failed due to " << tin::GetErrorStr(); } LOG(INFO) << "echo server is listening on port: " << kPort; while (true) { tin::net::TcpConn conn = listener->Accept(); if (tin::GetErrorCode() == 0) { tin::Spawn(&HandleClient, conn); } else { LOG(INFO) << "Accept failed due to " << tin::GetErrorStr(); } } return 0; } int main(int argc, char** argv) { tin::Initialize(); // set logging level. logging::SetMinLogLevel(logging::LOG_INFO); // set max p count. tin::Config config = tin::DefaultConfig(); config.SetMaxProcs(base::SysInfo::NumberOfProcessors()); // start the world. tin::PowerOn(TinMain, argc, argv, &config); // wait for power off tin::WaitForPowerOff(); // cleanup. tin::Deinitialize(); return 0; }
tin-project 官网
https://gitee.com/mycloudpeak/tin
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。