0

私は次のコードを持っています：

#include <stdio.h>
#include <pthread.h>
#define THREAD_CNT 10
#define ITER 100
#define PRINT 1

int lock;
unsigned long long int counter;

void spin_lock(int *p) {
    while(!__sync_bool_compare_and_swap(p, 0, 1));
}

void spin_unlock(int volatile *p) {
    asm volatile ("");
    *p = 0;
}

void *exerciser(void *arg) {
    unsigned long long int i;
    int id = (int)arg;
    for(i = 0; i < ITER; i++) {
        spin_lock(&lock);
        counter = counter + 1;
        if(PRINT) {
            printf("%d: Incrementing counter: %llu -> %llu\n", id, counter-1, counter);
        }
        spin_unlock(&lock);
    }
    pthread_exit(NULL);
}

int main(int argc, char *argv[]) {
    pthread_t thread[THREAD_CNT];
    counter = 0;
    int i;
    for(i = 0; i < THREAD_CNT; i++) {
        pthread_create(&thread[i], NULL, exerciser, (void *) i);
    }
    for(i = 0; i < THREAD_CNT; i++) {
        pthread_join(thread[i], NULL);
    }
    printf("Sum: %llu\n", counter);
    printf("Main: Program completed. Exiting.\n");
    pthread_exit(NULL);
}

PRINTが1として定義されている場合、最後に正しいカウンター値を取得します。

7: Incrementing counter: 996 -> 997
7: Incrementing counter: 997 -> 998
7: Incrementing counter: 998 -> 999
7: Incrementing counter: 999 -> 1000
Sum: 1000
Main: Program completed. Exiting.

0にするPRINTと、次のようになります（複数回実行）。

$ ./a.out
Sum: 991
Main: Program completed. Exiting.
$ ./a.out 
Sum: 1000
Main: Program completed. Exiting.
$ ./a.out 
Sum: 962
Main: Program completed. Exiting.
$ ./a.out 
Sum: 938
Main: Program completed. Exiting.

何が起こっているのかについての洞察はありますか？printステートメントを有効にすると、結果は（一貫して）正しいのに、無効にするとカウンターが目標値に達しないのはなぜですか？私はpthreadをかなり使用しましたが、スピンロックを直接使用した経験はあまりありません。

ヘルプやフィードバックをいただければ幸いです。

4

1 に答える 1

1

ロックメソッドは実際には何もしていません。引数は値によって渡されるため、ロックの値をグローバルにテスト/設定しているわけではありません。関数が取得する変数のコピーの値を変更するだけです。

代わりに、spin_lock / spin_unlockメソッドが&lock使用する整数（つまり）へのポインターを取得した場合、コードは機能するはずです。

printfはスレッドセーフであると想定されているため、耐荷重printfは、意図しない同期を引き起こすことでおそらく役立ちます。

于 2012-06-24T10:26:44.060 に答える