servcraft/p7Stackful协程库
servcraft/p7是使用C实现的stackful协程库,提供“半”透明的CSP并发。
目前,servcraft只支持Linux/GCC/pthread. 由于阻塞IO封装使用了epoll, 推荐使用Linux 2.6以上。
若要利用servcraft提供的GCC闭包功能,请使用主版本号不低于5的GCC.
servcraft/p7所使用的协程(coroutines, coro)提供类似goroutine的功能。
-
编写并发程序的过程较一般事件驱动框架更简单。每个协程假定自己和其他协程一样,被并发地调度且独立地执行,因而可以顺序编写逻辑。
-
为使用文件描述符的系统调用提供了IO阻塞-重调度接口。协程阻塞在IO操作上时自动暂停执行、引发重调度,IO就绪时重新获得调度权。
-
提供Actor风格的协程间通信。协程可以注册自身名字,并按注册的协程名向其他协程的内建邮箱中(零拷贝地)投递信息。
-
所有IO和协程间通信的阻塞接口都自带超时定时器。
-
提供协程间瘦自旋锁和读写自旋锁。读写自旋锁使用尽量公平对待读者、写者的机制。
简介和简单demo可以在这里获得。一个粗暴的echo server如下:
#include <stdio.h> #include "./net_common.h" // common header for necessary network APIs #include <sys/stat.h> #include "../servcraft/p7/libp7.h" #include "../servcraft/p7/p7_root_alloc.h" #include "../servcraft/include/model_alloc.h" void test_echo(void *arg) { intptr_t fd_conn_i64crap = (long long) arg; int fd_conn = (int) (fd_conn_i64crap & 0xFFFFFFFF); char msg[32]; memset(msg, 0, sizeof(char) * 32); int ret = p7_iowrap_timed(recv, P7_IOMODE_READ, 30000, fd_conn, msg, sizeof(msg), 0); switch (ret) { case -1: printf("internal error\n"); break; case -2: printf("p7 timed out\n"); break; default: p7_iowrap(send, P7_IOMODE_WRITE, fd_conn, msg, strlen(msg), 0); } close(fd_conn); } void test_timeout(void *arg) { long long fd_conn_i64crap = (long long) arg; int fd_conn = (int) (fd_conn_i64crap & 0xFFFFFFFF); printf("Timed out: %d\n", fd_conn); } void test_echo_wrapper(void *arg) { p7_coro_concat(test_echo, arg, 2048); } void test_startup(void *unused) { printf("startup\n"); } int main(int argc, char *argv[]) { __auto_type allocator = p7_root_alloc_get_allocator(); allocator->allocator_.closure_ = malloc; allocator->deallocator_.closure_ = free; allocator->reallocator_.closure_ = realloc; struct p7_init_config config; 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); int fd_listen; if ((fd_listen = socket(PF_INET, SOCK_STREAM, 0)) == -1) { perror("socket"); exit(1); } struct sockaddr_in lserv; 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, (struct sockaddr *) &lserv, sizeof(lserv)) == -1) { perror("bind"); exit(1); } if (listen(fd_listen, 5) == -1) { perror("listen"); exit(1); } while (1) { struct sockaddr_in rcli; socklen_t addrlen = sizeof(rcli); int fd_conn = p7_iowrap(accept, P7_IOMODE_READ, fd_listen, (struct sockaddr *) &rcli, &addrlen); intptr_t fd_conn_i64crap = fd_conn; p7_coro_create(test_echo_wrapper, (void *) fd_conn_i64crap, 512); } return 0; }
评论