pthreads - pthread の共有オブジェクト

Question

10gb のような巨大なサイズの共有オブジェクトに 16 個のスレッドがアクセスするサンプル プログラムを作成したいと考えています。を使用してオブジェクトのロックを取得できることはわかっていpthread_mutex_tますが、2 つ以上のスレッドが共有オブジェクトのばらばらの部分を同時に変更できるようにするにはどうすれば効率的ですか?

Answer 1

セマフォの使用についてはどうですか。リソースを共有するスレッドの数でセマフォを初期化できます。

    /* Includes */ 
#include <unistd.h>     /* Symbolic Constants */ 
#include <sys/types.h>  /* Primitive System Data Types */
#include <errno.h>      /* Errors */
#include <stdio.h>      /* Input/Output */
#include <stdlib.h>     /* General Utilities */
#include <pthread.h>    /* POSIX Threads */
#include <string.h>     /* String handling */
#include <semaphore.h>  /* Semaphore */

void semhandler ( void *ptr );

sem_t mutex;
int cntr=0; /* shared variable */

int main()
{
    int arg[2];
    pthread_t thread1;
    pthread_t thread2;

    arg[0] = 0;
    arg[1] = 1;

    /* initialize mutex to 2 to share resource with two threads*/
    /* Seconds Argumnet "0" makes the semaphore local to the process */
    sem_init(&mutex, 0, 2);

    pthread_create (&thread1, NULL, (void *) &semhandler, (void *) &arg[0]);
    pthread_create (&thread2, NULL, (void *) &semhandler, (void *) &arg[1]);

    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);

    sem_destroy(&mutex);

    exit(0);
} /* main() */

void semhandler ( void *ptr )
{
    int x;
    x = *((int *) ptr);
    printf("Thrd %d: Waiting to enter critical region...\n", x);
    sem_wait(&mutex);       /* down semaphore */
    if( x == 1 )
        cntr++;

    /* START CRITICAL REGION */
    printf("Thrd %d: Now in critical region...\n", x);
    printf("Thrd %d: New Counter Value: %d\n", x, cntr);
    printf("Thrd %d: Exiting critical region...\n", x);
    /* END CRITICAL REGION */
    sem_post(&mutex);       /* up semaphore */

    pthread_exit(0); /* exit thread */
}