servcraft/p7是使用C实现的stackful协程库，提供“半”透明的CSP并发。
目前，servcraft只支持Linux/GCC/pthread.由于阻塞IO封装使用了epoll,推荐使用Linux2.6以上。
若要利用servcraft提供的GCC闭包功能，请使用主版本号不低于5的GCC.
servcraft/p7所使用的协程（coroutines,coro）提供类似goroutine的功能。
编写并发程序的过程较一般事件驱动框架更简单。每个协程假定自己和其他协程一样，被并发地调度且独立地执行，因而可以顺序编写逻辑。
为使用文件描述符的系统调用提供了IO阻塞-重调度接口。协程阻塞在IO操作上时自动暂停执行、引发重调度，IO就绪时重新获得调度权。
提供Actor风格的协程间通信。协程可以注册自身名字，并按注册的协程名向其他协程的内建邮箱中（零拷贝地）投递信息。
所有IO和协程间通信的阻塞接口都自带超时定时器。
提供协程间瘦自旋锁和读写自旋锁。读写自旋锁使用尽量公平对待读者、写者的机制。
简介和简单demo可以在这里获得。一个粗暴的echoserver如下：
#include <stdio.h>#include "./net_common.h" //commonheaderfornecessarynetworkAPIs#include <sys/stat.h>#include "../servcraft/p7/libp7.h"#include "../servcraft/p7/p7_root_alloc.h"#include "../servcraft/include/model_alloc.h"voidtest_echo(void*arg){ intptr_tfd_conn_i64crap=(longlong)arg; intfd_conn=(int)(fd_conn_i64crap&0xFFFFFFFF); charmsg[32]; memset(msg,0,sizeof(char)*32); intret=p7_iowrap_timed(recv,P7_IOMODE_READ,30000,fd_conn,msg,sizeof(msg),0); switch(ret){ case-1: printf("internalerror\n"); break; case-2: printf("p7timedout\n"); break; default: p7_iowrap(send,P7_IOMODE_WRITE,fd_conn,msg,strlen(msg),0); } close(fd_conn);}voidtest_timeout(void*arg){ longlongfd_conn_i64crap=(longlong)arg; intfd_conn=(int)(fd_conn_i64crap&0xFFFFFFFF); printf("Timedout:%d\n",fd_conn);}voidtest_echo_wrapper(void*arg){ p7_coro_concat(test_echo,arg,2048);}voidtest_startup(void*unused){ printf("startup\n");}intmain(intargc,char*argv[]){ __auto_typeallocator=p7_root_alloc_get_allocator(); allocator->allocator_.closure_=malloc; allocator->deallocator_.closure_=free; allocator->reallocator_.closure_=realloc; structp7_init_configconfig; config.namespace_config.namespace_size=1024; config.namespace_config.rwlock_granularity=10; config.namespace_config.spintime=400; config.pthread_config.nthreads=atoi(argv[1]); config.pthread_config.at_startup=test_startup; config.pthread_config.arg_startup=NULL; p7_init(config); intfd_listen; if((fd_listen=socket(PF_INET,SOCK_STREAM,0))==-1){ perror("socket"); exit(1); } structsockaddr_inlserv; lserv.sin_family=AF_INET; lserv.sin_port=htons(8080); lserv.sin_addr.s_addr=inet_addr(argv[2]); bzero(&(lserv.sin_zero),8); if(bind(fd_listen,(structsockaddr*)&lserv,sizeof(lserv))==-1){ perror("bind"); exit(1); } if(listen(fd_listen,5)==-1){ perror("listen"); exit(1); } while(1){ structsockaddr_inrcli; socklen_taddrlen=sizeof(rcli); intfd_conn=p7_iowrap(accept,P7_IOMODE_READ,fd_listen,(structsockaddr*)&rcli,&addrlen); intptr_tfd_conn_i64crap=fd_conn; p7_coro_create(test_echo_wrapper,(void*)fd_conn_i64crap,512); } return0;}
评论