| 56 | } |
| 57 | |
| 58 | void master_service::on_trigger() |
| 59 | { |
| 60 | std::vector<acl::string>::const_iterator cit = url_list_.begin(); |
| 61 | for (; cit != url_list_.end(); ++cit) |
| 62 | { |
| 63 | const char* url = (*cit).c_str(); |
| 64 | for (int i = 0; i < var_cfg_http_cocurrent; i++) |
| 65 | { |
| 66 | // ����һ�������߳����������̳߳�ȥִ�� |
| 67 | acl::thread_job* job = new http_job(*var_thrpool, url, |
| 68 | var_cfg_dns_ip, var_cfg_dns_port); |
| 69 | var_thrpool->execute(job); |
| 70 | } |
| 71 | } |
| 72 | |
| 73 | // �ȴ��̳߳ؽ��� |
| 74 | var_thrpool->wait(); |
| 75 | } |
| 76 | |
| 77 | void master_service::proc_on_init() |
| 78 | { |