Function main

lib_acl_cpp/samples/thread_client/main.cpp:15–90

}

int main(int argc, char* argv[])
{
	int   ch, cocurrent = 1, count = 10, length = 1024;
	bool  keep_alive = false;
	acl::string server_addr("127.0.0.1:8888");

	// ��ʼ�� acl ��
	acl::acl_cpp_init();

	while ((ch = getopt(argc, argv, "hs:c:n:k")) > 0)
	{
		switch (ch)
		{
		case 'h':
			usage(argv[0]);
			return 0;
		case 'c':
			cocurrent = atoi(optarg);
			break;
		case 'n':
			count = atoi(optarg);
			break;
		case 'k':
			keep_alive = true;
			break;
		case 's':
			server_addr = optarg;
			break;
		default:
			break;
		}
	}

	struct timeval begin;
	gettimeofday(&begin, NULL);

	std::list<thread_client*> threads;

	for (int i = 0; i < cocurrent; i++)
	{
		// �����߳
		thread_client* thread = new thread_client(server_addr, keep_alive,
				count, length);

		// ���ô������߳�Ϊ�Ƿ���ģʽ���Ա���������Ե�� thread::wait
		// �ȴ��߳̽���
		thread->set_detachable(false);

		// ���̷߳��ڶ����
		threads.push_back(thread);

		// �����߳
		thread->start();
	}

	std::list<thread_client*>::iterator it = threads.begin();
	for (; it != threads.end(); ++it)
	{