Engine

#include	<Application.h>

class GameApp : public Application {
public:
	GameApp() {}

	virtual bool OnInit(const Commandline & cmd) override {
		if (cmd.Has("--debug")) {
			Logger::Instance().Initialize("game", "logs", ELog::Debug);
		} else {
			Logger::Instance().Initialize("game", "logs", ELog::Info);
		}

		/// 锁帧
		LockFPS(20);

		/// 填写其他初始化逻辑，当返回false时程序直接退出
		return true;
	}

	virtual void OnBreath() override {
		/// 这里填写需要每帧更新的逻辑
	}
};

RUN_APP(GameApp)

class Client : public IOListener {
public:
	Client() : _socket(new Socket()) {
	}

	~Client() {
		Close();
		delete _socket;
	}

	bool Connect(const std::string & ip, int port) {
		bool succ = _socket->Connect(ip, port);
		if (succ) BindIO(_socket->ctx, IO_READ); //! 我们只需要网络有数据来时通知
		return succ;
	}

	/// 实现数据可读时消息处理
	virtual void OnReadable() override {
		char buf[1024] = {0};

		int readed = 0;
		int recv = 0;

		while (true) {
			recv = _socket->Recv(buf, 1024);
			if (recv > 0) {
				//! TODO: process received data.
			} else if (recv == 0) {
				break;
			} else {
				Close(recv);
				break;
			}
		}
	}

	void Close(int reason = 0) {
		UnbindIO(); //! 关闭之前请取消IO事件监听
		_socket->Close();
	}

	bool Send(const char * p, size_t s) {
		return _socket->Send(p, s);
	}

private:
	Socket * _socket;
}

#include	<Script.h>

/// 注册公共变量或函数到Lua
GLua.Register("GameSetting")	//! 所有下面注册的属性或函数放在GameSetting中
	.Property("nPlayerCounter", &GPlayerCount, false)	//! 以地址方式注册属性，同时设置不可写
	.Property("nTime", &GetTime)	//! 以Getter方式注册属性，同时不注册属性的写方法（不可写）
	.Method("GetAById", &GetAById);	//! 注册全局Lua方法

/// 注册C++类到Lua
GLua.Register<A>("LuaA")
	.Property("nId", &A::id, false)
	.Property("sName", &A::GetName, &A::SetName)
	.Method("Msg", &A::SendMessage);

try {
	A * p = GLua.Get<A *>("me");	// 需要使用try，因为可能类型不匹配
} catch (...) {}

if (GLua.Is<A *>("me")) {} // 不需要try
GLua.Set<A *>("me", new A) // 不需要try
GLua.Call("GameSetting", "GetAById", false, 100); // 不需要try

int GetAById(LuaState & r) {
	int n = r.Get<int>(1);	// 不需要try
	...
}

-- 扩展名空间的方法
function XXX.yyy()
end

-- 扩展类静态方法
function LuaA.Test()
	print("hehe")
end

-- 扩展类成员方法，注意：这里用的是':'，因为需要使用self
function LuaA.apis:YYY()
end

#include	<Threads.h>

class DemoTask : public IThreadJob {
public:
	DemoTask(...) { ... }			//! 这里为该工作参数初始化
	virtual ~DemoTask() { ... }		//! 这里为工作结束时清理操作

	virtual void OnRun() { ... }	//! 工作的具体内容

private:
	...		//! 参数声明
};

int main() {
	Threads workers(4);	//! 创建含有一个4个工作线程的容器

	/// 增加100个并发任务（多余的会暂时等待空闲线程）
	for (int i = 0; i < 100; ++i) {
		workers.AddJob<DemoTask>(...);	// 传入工作需要的参数，这里自动调用 new DemoTask(...);
	}

	/// 等待所有的工作结束，如果不执行该操作，mgr超出生存期时会放弃未执行的任务。
	workers.Wait();
	return 0;
}

/// 添加一个500毫秒后执行的定时器
GScheduler.Add(500, [](uint64_t id) {
	printf("Timer's id : %llu", id);
});

/// 添加一个每500毫秒执行一次的定时器
GScheduler.Add(500, [](uint64_t id) {
	printf("Timer's id : %llu", id);
}, true);

/// 注册每天05:00:00时执行的计划任务
GScheduler.Add(5, 0, 0, [](uint64_t id) {
	printf("Task's id : %llu", id);
});

/// 是否存在定时器或计划任务
bool valid = GScheduler.IsValid(timer_id);

/// 取得一个定时器或计划多少毫秒后执行
double left = GScheduler.GetRemainTime(timer_id);

/// 取消一个定时器或计划任务
GScheduler.Cancel(timer_id);

scheduler.timer(500, function(id) end);
scheduler.timer(500, function(id) end, true);
scheduler.task(5, 0, 0, function(id) end);
scheduler.is_valid(timer_id);
scheduler.remain(timer_id);
scheduler.cancel(timer_id);

RootOfLogs						指定的日志根目录
|-- 20160803					首先日志会根据“年月日”分文件夹
|	|-- main_01_00_00.000.log	其次日志会按指定大小分文件记录，文件名为指定的"Name_时_分_秒.毫秒.log"
|	|-- main_01_27_18.193.log

/// 初始化日志。日志名为main, 放在logs目录下，输出等级为DEBUG，每个文件最大为4M
Logger::Instance().Initialize("main", "logs", Logger::Debug, 4 * 1024 * 1024);

/// 写日志
LOG_INFO("Hello");
LOG_DEBUG("Hello %d", 2);
LOG_ERR("Error : %s", "Test");
LOG_WARN("You have a warning");