Function thread_pool_main

lib_acl_cpp/src/ipc/ipc_service.cpp:50–99

};

static void thread_pool_main(REQ_CTX* ctx)
{

#ifdef ACL_WINDOWS
	HWND hWnd = ctx->req->get_hwnd();
	if (hWnd != NULL) {
		ctx->req->run(hWnd);
	} else
#endif
	if (ctx->service) {
		ipc_client* ipc = ctx->service->peek_conn();
		if (ipc == NULL) {
			logger_error("peek connect to %s error: %s",
				ctx->addr, last_serror());
		} else {
			ctx->req->run(ipc);

			// �������������Ȼ��������������ӳ���
			if (ipc->active()) {
				ctx->service->push_conn(ipc);
			}

			// �������ͷŶ�̬����
			else {
				delete ipc;
			}
		}
	} else {
		// IO ��Ϣģʽ

		ipc_client* ipc = NEW ipc_client(ctx->magic);

		// ������Ϣ������, ����ͬ��IPCͨ����ʽ
		if (!ipc->open(ctx->addr, 0)) {
			logger_error("open %s error(%s)",
				ctx->addr, last_serror());
		}

		// ���������������������
		else {
			ctx->req->run(ipc);
		}

		// ���� IPC ��
		delete ipc;
	}

	// �ͷ������߳��з���Ķ���
	acl_myfree(ctx);
}

static void* thread_once_main(REQ_CTX* ctx)
{