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;
}
评论