我正在尝试从每个线程运行给定数量的卷发。 pull_one_url()
是在pthread_create()
中从main()
中调用的功能。 cnt_limit
是一个全局变量,在main中设置,并且只能在线程中读取。
我有时看到的意外行为是本地计数变量被增加到较高的值。
对于给定的运行线程数为10,并且cnt_limit
(每个线程的卷发数)设置为10。
命令行运行:./a.out 10 10 10.140.71.12
意外输出是:
10 2682
10 2858
10 2804
10 2988
10 2871
10 2940
10 2864
10 2609
10 2816
10 2893
源代码:
#include <stdio.h>
#include <pthread.h>
#include <curl/curl.h>
#include <stdlib.h>
size_t write_data(void *buffer, size_t size, size_t nmemb, void *userp)
{
// printf("got response\n");
return size * nmemb;
}
int cnt_limit;
static void *pull_one_url(void *url)
{
CURL *curl;
int cnt;
int count = 0;
for (cnt=0; cnt < cnt_limit; cnt++) {
CURLcode res;
curl = curl_easy_init();
curl_easy_setopt(curl, CURLOPT_URL, url);
curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 1L);
curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 1L);
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data);
res = curl_easy_perform(curl);
int response_code;
if (res == CURLE_OK) {
curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &response_code);
//printf("%d\n", response_code);
}
else {
//printf("400\n");
}
curl_easy_cleanup(curl);
count++;
//printf("%d\n", cnt);
}
printf("%d %d\n", cnt_limit, count);
return NULL;
}
int main(int argc, char **argv)
{
int n = atoi(argv[1]);
cnt_limit=atoi(argv[2]);
pthread_t tid[n];
int i;
curl_global_init(CURL_GLOBAL_ALL);
for(i = 0; i< n; i++) {
int error = pthread_create(&tid[i],
NULL,
pull_one_url,
(void *) argv[3]);
if(0 != error)
fprintf(stderr, "Couldn't run thread number %d, errno %d\n", i, error);
//else
//fprintf(stderr, "Thread %d, gets %s\n", i, argv[2]);
}
/* now wait for all threads to terminate */
for(i = 0; i< n; i++) {
pthread_join(tid[i], NULL);
//fprintf(stderr, "Thread %d terminated\n", i);
}
return 0;
}
编辑:在循环注释掉libcurl代码之后,我还没有观察到这种行为。但是报告的行为也不是很一致。
[花了很多时间试图理解这一点之后,我将其发布在这里。我认为我犯了一些愚蠢的错误。任何帮助将不胜感激。
count ++是否已在任何地方使用,因为您已经在增加cnt ++?