language:cpp:boost
编辑 编辑 编辑 编辑 编辑 在这里start()和hello()方法都必须是static方法。 编辑 编辑 编辑 编辑 language/cpp/boost.txtbuild
bjam link=static
bjam link=static runtime-link=static
asio
#if defined(WIN32)#define _WIN32_WINNT 0x0501#else#ifndef _GNU_SOURCE#define _GNU_SOURCE#endif#include <unistd.h>#include <linux/aio_abi.h>#include <sys/syscall.h>#include <sys/eventfd.h>#endif#include <stdio.h>#include <stdlib.h>#include <stdint.h>#include <boost/asio.hpp>#include <boost/bind.hpp> #if defined(WIN32) static void on_read_done(boost::asio::io_service& serv,const boost::system::error_code& bsec,char* p_buf){ if (bsec){
printf(" 发生错误 *\n");
}
else{
printf("读取到的文件内容:\n%s\n",p_buf);
}
serv.stop();} int main(){
HANDLE h_file = CreateFileA(
"c:\\test_aio.cpp",
FILE_READ_DATA,FILE_SHARE_READ,NULL,OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED,
NULL );
boost::asio::io_service io_serv;
boost::asio::windows::stream_handle normal_file(io_serv,h_file); char* buf = (char*)malloc(100);
memset(buf,0,100);
boost::asio::async_read(
normal_file,
boost::asio::buffer(buf,90),
boost::bind(&on_read_done,boost::ref(io_serv),_1,buf)
);
boost::asio::io_service::work idle(io_serv);
io_serv.run(); free(buf); return 0;} #else static void on_read_done(boost::asio::io_service& serv,aio_context_t& ctx,const boost::system::error_code& bsec,std::size_t bytes){
if (bytes != sizeof(uint64_t)){
printf(" 发生错误 *\n");
}
else{
struct io_event event_io[1];
syscall(SYS_io_getevents,ctx,1,1,event_io,0); struct iocb* p_operation = (struct iocb*)(event_io[0].obj); if (event_io[0].res2 != 0){
printf("读取数据发生错误\n");
}
else if (uint64_t(event_io[0].res) != uint64_t(p_operation->aio_nbytes)){
printf("读取部分成功: 请求读取/实际读取字节敿 %llu/%lld\n",p_operation->aio_nbytes,event_io[0].res);
}
else{
printf("读取到的文件内容:\n%s\n",(char*)(p_operation->aio_buf));
}
}
serv.stop();} int main(){ 准备异步IO上下斿 unsigned int max_io_cnt = 10;
aio_context_t ctx; memset(&ctx,0,sizeof(ctx));
if (syscall(SYS_io_setup,max_io_cnt,&ctx) != 0){
printf("准备异步IO上下文失败\n");
return -1;
} 准备eventfd,关联到boost::asio::posix::stream_descriptor,发起异步读取操作,等待事件发生
boost::asio::io_service io_serv;
boost::asio::posix::stream_descriptor io_notify(io_serv); int notify_fd = eventfd(0,EFD_NONBLOCK | EFD_CLOEXEC);
io_notify.assign(notify_fd); uint64_t done_io_cnt = 0;
boost::asio::async_read(
io_notify,
boost::asio::buffer(&done_io_cnt,sizeof(done_io_cnt)),
boost::bind(&on_read_done,boost::ref(io_serv),boost::ref(ctx),_1,_2)
); 发起异步读取请求
int fd = open("/home/test_aio.cpp",O_RDWR); char* buf = (char*)malloc(100);
memset(buf,0,100); struct iocb* p_operation = (struct iocb*)malloc(sizeof(struct iocb)); memset(p_operation,0,sizeof(struct iocb));
p_operation->aio_lio_opcode = IOCB_CMD_PREAD;
p_operation->aio_fildes = fd;
p_operation->aio_buf = (uint64_t)(uintptr_t)buf;
p_operation->aio_nbytes = 90;
p_operation->aio_flags = IOCB_FLAG_RESFD;
p_operation->aio_resfd = notify_fd; 事件循环
if (syscall(SYS_io_submit,ctx,1,&p_operation) == 1){
boost::asio::io_service::work idle(io_serv);
io_serv.run();
}
else{
printf("发起异步IO请求失败\n");
}
close(notify_fd);
close(fd);
syscall(SYS_io_destroy,ctx);
free(buf); return 0;} #endifthread
第一种情况：全局函数
#include <boost/thread/thread.hpp> #include <iostream> void hello() {
std::cout <<
"Hello world, I''m a thread!"
<< std::endl; } int main(int argc, char* argv[]) {
boost::thread thrd(&hello);
thrd.join();
return 0; }第二种情况：类重载operator()
#include <boost/thread/thread.hpp> #include <boost/thread/mutex.hpp> #include <iostream>
boost::mutex io_mutex; struct count
{
count(int id) : id(id) { } void operator()()
{
for (int i = 0; i < 10; ++i)
{
boost::mutex::scoped_lock
lock(io_mutex);
std::cout << id << ": "
<< i << std::endl;
}
} int id; }; int main(int argc, char* argv[]) {
boost::thread thrd1(count(1));
boost::thread thrd2(count(2));
thrd1.join();
thrd2.join();
return 0; }第三种情况：类内部static函数
#include <boost/thread/thread.hpp>#include <iostream> class HelloWorld{public:
static void hello()
{
std::cout <<
"Hello world, I''m a thread!"
<< std::endl;
}
static void start()
{
boost::thread thrd( hello );
thrd.join();
} }; int main(int argc, char* argv[]){
HelloWorld::start(); return 0;}第四种情况：使用boost::bind
#include <boost/thread/thread.hpp>#include <boost/bind.hpp>#include <iostream> class HelloWorld{public:
void hello()
{
std::cout <<
"Hello world, I''m a thread!"
<< std::endl;
}
void start()
{
boost::function0< void> f = boost::bind(&HelloWorld::hello,this);
或boost::function<void()> f = boost::bind(&HelloWorld::hello,this);
boost::thread thrd( f );
thrd.join();
} }; int main(int argc, char* argv[]){
HelloWorld hello;
hello.start();
return 0;}第五种情况：Singleton模式
#include <boost/thread/thread.hpp>#include <boost/bind.hpp>#include <iostream> class HelloWorld{public:
void hello()
{
std::cout <<
"Hello world, I''m a thread!"
<< std::endl;
}
static void start()
{
boost::thread thrd( boost::bind
(&HelloWorld::hello,&HelloWorld::getInstance() ) ) ;
thrd.join();
}
static HelloWorld& getInstance()
{
if ( !instance )
instance = new HelloWorld;
return *instance;
}private:
HelloWorld(){}
static HelloWorld* instance; }; HelloWorld* HelloWorld::instance = 0; int main(int argc, char* argv[]){
HelloWorld::start();
return 0;}第六种情况：类外用类内函数
#include <boost/thread/thread.hpp>#include <boost/bind.hpp>#include <string>#include <iostream> class HelloWorld{public:
void hello(const std::string& str)
{
std::cout <<str<< std::endl;
}}; int main(int argc, char* argv[]){
HelloWorld obj;
boost::thread thrd( boost::bind(&HelloWorld::hello,&obj,"Hello
world, I''m a thread!" ) ) ;
thrd.join();
return 0;}
