testthreadpool.cpp

spserver 是一个实现了半同步/半异步(Half-Sync/Half-Async)和领导者/追随者(Leader/Follower) 模式的服务器框架

/*
 * Copyright 2007 Stephen Liu
 * For license terms, see the file COPYING along with this library.
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <errno.h>
#include <stdarg.h>

#include "spthreadpool.hpp"

extern int errno;

void threadFunc( void *arg )
{
	int seconds = (int) arg;

	fprintf( stdout, "  in threadFunc %d\n", seconds );
	fprintf( stdout, "  thread#%ld\n", pthread_self() );
	sleep( seconds );
	fprintf( stdout, "  done threadFunc %d\n", seconds);
}

int main( int argc, char ** argv )
{
	SP_ThreadPool pool( 2 );

	fprintf( stdout, "**main** dispatch 3\n" );
	pool.dispatch( threadFunc, (void*)3 );
	fprintf( stdout, "**main** dispatch 6\n");
	pool.dispatch( threadFunc, (void*)6 );
	fprintf( stdout, "**main** dispatch 7\n");
	pool.dispatch( threadFunc, (void*)7 );

	fprintf( stdout, "**main** done first\n" );
	sleep( 20 );
	fprintf( stdout, "\n\n" );

	fprintf( stdout, "**main** dispatch 3\n" );
	pool.dispatch( threadFunc, (void *) 3 );
	fprintf( stdout, "**main** dispatch 6\n" );
	pool.dispatch( threadFunc, (void *) 6 );
	fprintf( stdout, "**main** dispatch 7\n");
	pool.dispatch( threadFunc, (void *) 7 );

	fprintf( stdout, "**main done second\n" );

	sleep(20);

	return 0;
}