Function main

lib_acl/samples/thread/thread_pool1/main.cpp:191–242

}

int main(int argc acl_unused, char *argv[] acl_unused)
{
	acl_pthread_pool_t *thr_pool;
	int  max_threads = 20;  /* ��ಢ��20���߳� */
	int  idle_timeout = 10; /* ÿ�������߳̿���10����Զ��˳� */
	static __thread ACL_VSTRING *buf = NULL;

	if (1) {
		test_thread_pool();
		exit (0);
	}

	buf = acl_vstring_alloc(256);
	acl_vstring_sprintf(buf, "in main thread, id=%u",
		(unsigned int) acl_pthread_self());
	acl_pthread_atexit_add(buf, main_thread_atexit);


	thr_pool = thr_pool_create(max_threads, idle_timeout);
	run_thread_pool(thr_pool);

	if (0) {
		/* ����������� acl_pthread_pool_destroy�������ڵ������̳߳����ٺ�����
		 * ���̱߳�����֪ͨ�����߳��˳������п����̲߳��صȴ����г�ʱʱ�����˳�,
		 */
		printf("> wait all threads to be idle and free thread pool\r\n");
		/* ���������̳߳� */
		acl_pthread_pool_destroy(thr_pool);
	} else {
		/* ��Ϊ���������� acl_pthread_pool_destroy���������п����̶߳��ǵ�����
		 * ��ʱʱ�䵽�����˳�
		 */
		while (1) {
			int   ret;

			ret = acl_pthread_pool_size(thr_pool);
			if (ret == 0)
				break;
			printf("> current threads in thread pool is: %d\r\n", ret);
			sleep(1);
		}
		/* �̳߳��еĹ����߳���Ϊ0ʱ�����̳߳� */
		printf("> all worker thread exit now\r\n");
		acl_pthread_pool_destroy(thr_pool);
	}

	/* ���̵߳ȴ��û����ն����������ַ����˳� */
	printf("> enter any key to exit\r\n");
	getchar();

	return (0);
}