boost高併發網路框架 執行緒池

include

#include

"authenhandle.h"

#include

"configure.h"

#ifdef win32 //for windows nt/2000/xp

#include

#include

#include

"gelsserver.h"

#pragma comment(lib,

"ws2_32.lib")#

else

//for unix

#include

socket

.h>

//    #include

//    #include

//    #include

#include

//socket

//    #include

#include

//gethostname

// #include

#include

#include

<

string

.h>

//memset

typedef

intsocket

;typedef

struct

sockaddr_in

sockaddr_in

;typedef

struct

sockaddr

sockaddr;#

ifdef m_i386

typedef

intsocklen_t;#

endif

#define

bool

int#

define invalid_socket    -1

#define socket_error     -1

#define

true             1

#define

false             0

#endif

//end #ifdef win32

static

int count111 = 0;

static

time_t oldtime = 0, nowtime = 0;

#include

#include

<

iostream

>

#include

#include

bind

.hpp>

#include

#include

#include

using

namespace

std;

using boost:

:asio:

:ip:

:tcp;

class io_service_pool

:public boost:

:noncopyable

}void start()}

void join()}

void stop()}

boost:

:asio:

:io_service& get_io_service(

)return io_service;

}private

:typedef boost:

:shared_ptr:asio:

:io_service> io_service_sptr;

typedef boost:

:shared_ptr:asio:

:io_service:

:work> work_sptr;

typedef boost:

:shared_ptr:thread> thread_sptr;

boost:

:mutex mtx;

std:

:vector

io_services_;

std:

:vector

work_;

std:

:vector

threads_;

std:

:size_t next_io_service_;};

boost:

:mutex cout_mtx;

int packet_size = 0;

enum

;class session

virtual

~session(

)tcp:

:socket

&socket()

inline

void start(

)void handle_read(

const boost:

:system

::error_code&

error

,size_t bytes_transferred)

boost:

:asio:

:async_write(socket_, boost:

:asio:

:buffer(data_, bytes_transferred)

,boost:

:bind

(&session:

:handle_write,

this

, boost:

:asio:

:placeholders:

:error))

;}else

}void handle_write(

const boost:

:system

::error_code&

error

)else

}private

:tcp:

:socket socket_;

char data_[max_packet_len]

;int recv_times;};

class server

void handle_accept(session* new_session,

const boost:

:system

::error_code&

error

)else

new_session =

new session(io_service_pool_.get_io_service())

;acceptor_.async_accept(new_session-

>

socket()

,boost:

:bind

(&server:

:handle_accept,

this

, new_session, boost:

:asio:

:placeholders:

:error))

;}void run(

)private

:io_service_pool io_service_pool_;

tcp:

:acceptor acceptor_;};

int main(

)return 0;