0

そんなコードがあります。グローバル キューがあり、posix スレッドで新しい要素を追加しますが、すべてを追加した後、スクリーン キューに出力すると、すべての要素が同じであることがわかります

#include <fstream>
#include <iostream>
#include <pthread.h> 
#include <queue>
#include <stdlib.h>
#include <string>
#include <unistd.h>
#include <cassert>

std::queue<int> q;
pthread_mutex_t set_queue_mutex;

void* producer(void*)
{
    srand(time(NULL));
    size_t m = rand() % 100 + 1;
    usleep(m/1000);
    size_t n = rand() % 100 + 1;
    int s = q.size();
    pthread_mutex_lock(&set_queue_mutex);
    q.push(n);
    pthread_mutex_unlock(&set_queue_mutex);
}
int main(int c, char** v)
{
    int n = 0;
    int m = 0;

    ///* Usage */
    if(c == 3)
    {
        n = atoi(v[1]);
        m = atoi(v[2]);
    }
    else
    {
        std::cout << "Wrong count of parameters, see usage: test $1 $2" << std::endl;
        exit(0);
    }
    pthread_t* t1 = new pthread_t[n];
    assert(t1 != 0);
    pthread_t* t2 = new pthread_t[m];
    assert(t2 != 0);

    for(int i = 0; i < n; ++i)
    {
        pthread_create(&t1[i], 0, &producer, 0);
        pthread_join(t1[i], 0);
    }

    while(q.size() != 0)
    {
        std::cout << q.front() << std::endl;
        q.pop();
    }

    return 0;
}

例 --- ./main 3 3 画面に表示される --- 16 16 16

スレッドがミューテックスを使用して同期されているのはなぜですか?

4

1 に答える 1

2

srand()毎回電話してはいけません。コールを に移動しますmain。それ以外の場合、値は秒の境界でのみ変更されるはずです。

于 2013-10-29T09:32:31.923 に答える