多线程程序中计数的意外增量

问题描述 投票:3回答:1

我正在尝试从每个线程运行给定数量的卷发。 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代码之后,我还没有观察到这种行为。但是报告的行为也不是很一致。

[花了很多时间试图理解这一点之后,我将其发布在这里。我认为我犯了一些愚蠢的错误。任何帮助将不胜感激。

c multithreading libcurl
1个回答
-1
投票

count ++是否已在任何地方使用,因为您已经在增加cnt ++?

© www.soinside.com 2019 - 2024. All rights reserved.