testthread.h

模仿wiondws写的linux/freeBSD系统的IOCP

#ifndef _TEST_H
#define _TEST_H
#include "utility/thread.h"
#include "iocp/iocomplete.h"
struct userContext
{
	IO_CONTEXT ioop;
	char buf[1024];
};

class cpuWorker : public runnable
{
public:
	cpuWorker(){}

	bool run();
};

class listener : public runnable
{

public:
	 listener(const std::string &ip,int port,int backlog):
	  ip(ip),port(port),backlog(backlog),
	  terminated(false),count(0)

	  {}

    void setTrig(IocpHandle iocp)
	{
		this->iocp = iocp;
	}

	bool run();

	void setTerminated()
	{
		terminated = true;
	}


private:
	int count;
	int listenfd;
	std::string ip;
	int port;
	int backlog;
	bool terminated;
	IocpHandle iocp;

};


class completeWorker : public runnable
{
public:
	completeWorker(IocpHandle iocp):iocp(iocp){}
	bool run();

private:
	IocpHandle iocp;
};

#endif