検索

ホームページ  >  記事  >  運用・保守  >  Linux でスレッド同期を実装するにはいくつかの方法があります

Linux でスレッド同期を実装するにはいくつかの方法があります

青灯夜游
青灯夜游オリジナル
2022-07-01 19:39:234911ブラウズ

6 つの方法: 1. ミューテックス ロックは、本質的にロックとロック解除の 2 つの状態を持つ特別なグローバル変数です; 2. スピン ロックは、無限ループ、ノンストップ ポーリングです; 3 、セマフォは、制限された共有リソースにアクセスするスレッドの数を制御する 4. 条件変数: 特定の条件が満たされた場合に呼び出しスレッドを実行し、条件が満たされない場合はブロックして起動を待機します。 5. 読み取り/書き込みロック:一度に起動できるのは 1 つだけです 書き込みモードで読み取り/書き込みロックを占有できるスレッドは 1 つだけです; 6. バリアは、ユーザーが複数のスレッドの並列作業を調整するための同期メカニズムです。

Linux でスレッド同期を実装するにはいくつかの方法があります

#このチュートリアルの動作環境: linux7.3 システム、Dell G3 コンピューター。

Linux でスレッド同期を実現する 6 つの方法

次に、スレッドの安全性の例を示します: 

#include<stdio.h>
#include<pthread.h>

int ticket_num=10000000;

void *sell_ticket(void *arg) {
    while(ticket_num>0) {
	ticket_num--;
    }
}

int main() {
    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &sell_ticket, NULL);
    pthread_create(&t2, NULL, &sell_ticket, NULL);
    pthread_create(&t3, NULL, &sell_ticket, NULL);
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
    printf("ticket_num=%d\n", ticket_num);
    return 0;
}

実行結果は次のとおりです:

# gcc no_lock_demo.c -o no_lock_demo.out -pthread
# ./no_lock_demo.out 
ticket_num=-2

操作の最終結果は固定されておらず、0 または -1 になる可能性があります。ticket_num 変数がインベントリを表す場合、インベントリは負の値になるため、スレッドの安全性を確保するためにスレッド同期を導入する必要があります。

Linux では、スレッド同期を処理するさまざまな方法が提供されています。最も一般的に使用されるのは、ミューテックス ロック、スピン ロック、セマフォです。

ミューテックス ロック

ミューテックス ロックの本質は、ロックとロック解除の 2 つの状態を持つ特別なグローバル変数です。ロック解除ミューテックス ロックは、スレッドによってミューテックスが取得されると、そのミューテックスはロックされ、ロック状態になります。その後、そのスレッドだけがロックを開く権限を持ち、ミューテックスを取得したい他のスレッドはロックされます。ミューテックスのロックが解除されるまでブロックされます。

ミューテックス ロックのタイプ:

  • 通常のロック (PTHREAD_MUTEX_NORMAL): ミューテックス ロックのデフォルトのタイプ。スレッドが共通ロックをロックすると、ロックを要求した残りのスレッドは待機キューを形成し、ロックが解除された後、優先順位に従ってロックを取得するため、リソース割り当ての公平性が確保されます。ロックされている通常のロックをスレッドが再度ロックすると、デッドロックが発生します。別のスレッドによってロックされた通常のロックをアンロックしたり、アンロックされた通常のロックを再度アンロックすると、予期しない結果が生じます。

  • エラーチェック ロック (PTHREAD_MUTEX_ERRORCHECK): スレッドがすでにロックされているエラーチェック ロックを再度ロックすると、ロック操作は EDEADLK を返します (別のスレッドによってロックされているスレッドの場合)。異常検出ロックを解除するか、すでに解除されている異常検出ロックを再度解除すると、解除動作は EPERM に戻ります。

  • ネストされたロック (PTHREAD_MUTEX_RECURSIVE): このロックを使用すると、スレッドはデッドロックなしでロックを解放する前に複数回ロックできます。他のスレッドがこのロックを取得したい場合は、現在のロックを所有者が取得する必要があります。複数のロック解除操作を実行します。別のスレッドによってロックされているネストされたロックをロック解除する場合、またはすでにロック解除されているネストされたロックを再度ロック解除する場合、ロック解除操作は EPERM を返します。

  • デフォルト ロック (PTHREAD_MUTEX_DEFAULT): スレッドがすでにロックされているデフォルト ロックを再度ロックするか、別のスレッドによってロックされているデフォルト ロックをアンロックするか、ロックされていないデフォルト ロックをアンロックすると、予期せぬ結果が生じる可能性があるため、このロックは実装時に上記の 3 つのロックのいずれかにマップされる可能性があります。

関連メソッド: 

// 静态方式创建互斥锁
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; 

// 动态方式创建互斥锁，其中参数mutexattr用于指定互斥锁的类型，具体类型见上面四种，如果为NULL，就是普通锁。
int pthread_mutex_init (pthread_mutex_t* mutex,const pthread_mutexattr_t* mutexattr);

int pthread_mutex_lock(pthread_mutex_t *mutex); // 加锁，阻塞
int pthread_mutex_trylock(pthread_mutex_t *mutex); // 尝试加锁，非阻塞
int pthread_mutex_unlock(pthread_mutex_t *mutex); // 解锁

例: 

#include<stdio.h>
#include<pthread.h>

int ticket_num=10000000;

pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;

void *sell_ticket(void *arg) {
    while(ticket_num>0) {
	pthread_mutex_lock(&mutex);
	if(ticket_num>0) {
	    ticket_num--;
	}
	pthread_mutex_unlock(&mutex);
    }
}

int main() {
    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &sell_ticket, NULL);
    pthread_create(&t2, NULL, &sell_ticket, NULL);
    pthread_create(&t3, NULL, &sell_ticket, NULL);
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
    printf("ticket_num=%d\n", ticket_num);
    return 0;
}

スピン ロック

スピン ロックは名前が示すように、常にポーリングする無限ループです。スレッドがスピン ロックを取得できない場合、ミューテックス ロックのようにブロッキング スリープ状態にはなりませんが、ロックを取得するために継続的にポーリングします。スピン ロックがすぐに取得できる場合は、スピン ロックが解放されると、パフォーマンスは非常に高くなりますが、スピン ロックが長時間解放されない場合、または大量の IO ブロックが発生した場合でも、ロックを取得している他のスレッドが継続的にポーリングすることになります。 CPU 使用率、特に CPU 時間は 100% に達します。

関連メソッド: 

int pthread_spin_init(pthread_spinlock_t *lock, int pshared); // 创建自旋锁

int pthread_spin_lock(pthread_spinlock_t *lock); // 加锁，阻塞
int pthread_spin_trylock(pthread_spinlock_t *lock); // 尝试加锁，非阻塞
int pthread_spin_unlock(pthread_spinlock_t *lock); // 解锁

例: 

#include<stdio.h>
#include<pthread.h>

int ticket_num=10000000;

pthread_spinlock_t spinlock;

void *sell_ticket(void *arg) {
    while(ticket_num>0) {
	pthread_spin_lock(&spinlock);
	if(ticket_num>0) {
	    ticket_num--;
	}
	pthread_spin_unlock(&spinlock);
    }
}

int main() {
    pthread_spin_init(&spinlock, 0);
    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &sell_ticket, NULL);
    pthread_create(&t2, NULL, &sell_ticket, NULL);
    pthread_create(&t3, NULL, &sell_ticket, NULL);
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
    printf("ticket_num=%d\n", ticket_num);
    return 0;
}

セマフォ

セマフォは、制限されたアクセスを制御するために使用されるカウンターです。リソースを共有しているスレッドの数。

関連メソッド: 

// 创建信号量
// pshared：一般取0，表示调用进程的信号量。非0表示该信号量可以共享内存的方式，为多个进程所共享(Linux暂不支持)。
// value：信号量的初始值，可以并发访问的线程数。
int sem_init (sem_t* sem, int pshared, unsigned int value);

int sem_wait (sem_t* sem); // 信号量减1，信号量为0时就会阻塞

int sem_trywait (sem_t* sem); // 信号量减1，信号量为0时返回-1，不阻塞

int sem_timedwait (sem_t* sem, const struct timespec* abs_timeout); // 信号量减1，信号量为0时阻塞，直到abs_timeout超时返回-1

int sem_post (sem_t* sem); // 信号量加1

例: 

#include<stdio.h>
#include<pthread.h>
#include <semaphore.h>

int ticket_num=10000000;

sem_t sem;

void *sell_ticket(void *arg) {
    while(ticket_num>0) {
	sem_wait(&sem);
	if(ticket_num>0) {
	    ticket_num--;
	}
	sem_post(&sem);
    }
}

int main() {
    sem_init(&sem, 0, 1); // value=1表示最多1个线程同时访问共享资源，与互斥量等价
    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &sell_ticket, NULL);
    pthread_create(&t2, NULL, &sell_ticket, NULL);
    pthread_create(&t3, NULL, &sell_ticket, NULL);
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
    printf("ticket_num=%d\n", ticket_num);
    return 0;
}

条件変数

条件変数を使用すると、呼び出しスレッドは特定の条件が発生するまで待機できます。特定の条件下で実行され、条件が満たされない場合はブロックして起動を待ちます。ミューテックス ロックと組み合わせて使用​​する必要があります。

条件変数は、プロデューサー モデルとコンシューマー モデルでよく使用されます。

関連メソッド: 

pthread_cond_t cond=PTHREAD_COND_INITIALIZER; // 创建条件变量，一个互斥锁可以对应多个条件变量

int pthread_cond_wait (pthread_cond_t* cond,pthread_mutex_t* mutex); // 阻塞等待条件满足，同时释放互斥锁mutex

int pthread_cond_timedwait (pthread_cond_t* cond,
    pthread_mutex_t* mutex,
    const struct timespec* abstime); // 带超时的阻塞等待条件满足，同时释放互斥锁mutex

// 从条件变量cond中唤出一个线程，令其重新获得原先的互斥锁
// 被唤出的线程此刻将从pthread_cond_wait函数中返回，但如果该线程无法获得原先的锁，则会继续阻塞在加锁上。
int pthread_cond_signal (pthread_cond_t* cond);

// 从条件变量cond中唤出所有线程
int pthread_cond_broadcast (pthread_cond_t* cond);

例: 

#include<stdio.h>
#include<pthread.h>

int max_buffer=10;
int count=0;

pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t notempty=PTHREAD_COND_INITIALIZER;
pthread_cond_t notfull=PTHREAD_COND_INITIALIZER;

void *produce(void *args) {
    while(1) {
        pthread_mutex_lock(&mutex);
        while(count == max_buffer) {
            printf("buffer is full, wait...\n");
            pthread_cond_wait(&notfull, &mutex);
        }
        printf("produce ...\n");
        count++;
        sleep(1);
        pthread_cond_signal(&notempty);
        pthread_mutex_unlock(&mutex);
    }

}

void *consumer(void *args) {
    while(1) {
        pthread_mutex_lock(&mutex);
        while(count == 0) {
            printf("buffer is empty, wait...\n");
            pthread_cond_wait(&notempty, &mutex);
        }
        printf("consumer ...\n");
        count--;
        sleep(1);
        pthread_cond_signal(&notfull);
        pthread_mutex_unlock(&mutex);
    }

}

int main() {
    pthread_t t1,t2,t3,t4;
    pthread_create(&t1, NULL, &produce, NULL);
    pthread_create(&t2, NULL, &produce, NULL);

    pthread_create(&t3, NULL, &consumer, NULL);
    pthread_create(&t4, NULL, &consumer, NULL);

    pthread_join(t1, NULL);
    return 0;
}

読み取り/書き込みロック

読み取り/書き込みロックには、次の 3 つの状態があります。読み取りモード ロック状態は書き込みモード、ロック状態は書き込みモード、アンロック状態は書き込みモードです。書き込みモードで読み取り/書き込みロックを保持できるスレッドは一度に 1 つだけですが、読み取りモードでは複数のスレッドが同時に読み取り/書き込みロックを保持できます。読み書きロックは共有排他ロックとも呼ばれます。読み書きロックが読み取りモードでロックされている場合は共有モードでロックされ、書き込みモードでロックされている場合は排他モードでロックされます。読み書きロック共有、読み取りと書き込みは相互に排他的です。

書き込みモードで読み取り/書き込みロックを占有できるのは一度に 1 つのスレッドだけですが、読み取りモードでは複数のスレッドが同時に読み取り/書き込みロックを保持できます。したがって、読み取り/書き込みロックでは、ミューテックスと比較してより高い並列処理が可能になります。読み取り/書き込みロックは、データ構造への読み取り数が書き込み数よりもはるかに多い状況に非常に適しています。

関連メソッド: 

// 创建读写锁
pthread_rwlock_t rwlock=PTHREAD_RWLOCK_INITIALIZER;

int pthread_rwlock_rdlock(pthread_rwlock_t *rwlock); // 加读锁，阻塞
int pthread_rwlock_wrlock(pthread_rwlock_t *rwlock); // 加写锁，阻塞
int pthread_rwlock_unlock(pthread_rwlock_t *rwlock); // 释放读锁或者写锁

int pthread_rwlock_tryrdlock(pthread_rwlock_t *rwlock); // 尝试加读锁，非阻塞
int pthread_rwlock_trywrlock(pthread_rwlock_t *rwlock); // 尝试加写锁，非阻塞

例:

#include <stdio.h>
#include <pthread.h>

pthread_rwlock_t rwlock=PTHREAD_RWLOCK_INITIALIZER;

void *read(void *arg) {
    while(1) {
        pthread_rwlock_rdlock(&rwlock);
        rintf("read message.\n");
        sleep(1);
        pthread_rwlock_unlock(&rwlock);
        sleep(1);
    }
}
void *write(void *arg) {
    while(1) {
        pthread_rwlock_wrlock(&rwlock);
        printf("write message.\n");
        sleep(1);
        pthread_rwlock_unlock(&rwlock);
        sleep(1);
    }
}

int main(int argc,char *argv[]) {
    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &read, NULL);
    pthread_create(&t2, NULL, &read, NULL);

    pthread_create(&t3, NULL, &write, NULL);

    pthread_join(t1, NULL);
    return 0;
}

屏障

屏障（barrier)是用户协调多个线程并行工作的同步机制。屏障允许每个线程等待，直到所有的合作线程都到达某一点，然后所有线程都从该点继续执行。pthread_join函数就是一种屏障，允许一个线程等待，直到另一个线程退出。但屏障对象的概念更广，允许任意数量的线程等待，直到所有的线程完成处理工作，而线程不需要退出，当所有的线程达到屏障后可以接着工作。

相关方法：

// 创建屏障
int pthread_barrier_init(pthread_barrier_t *barrier,const pthread_barrrierattr_t *attr,unsigned int count)

// 阻塞等待，直到所有线程都到达
int pthread_barrier_wait(pthread_barrier_t *barrier)

例子：

#include <stdio.h>
#include <pthread.h>

pthread_barrier_t barrier;

void *go(void *arg){
    sleep (rand () % 10);
    printf("%lu is arrived.\n", pthread_self());
    pthread_barrier_wait(&barrier);
    printf("%lu go shopping...\n", pthread_self());
}

int main() {
    pthread_barrier_init(&barrier, NULL, 3);

    pthread_t t1,t2,t3;
    pthread_create(&t1, NULL, &go, NULL);
    pthread_create(&t2, NULL, &go, NULL);
    pthread_create(&t3, NULL, &go, NULL);

    pthread_join(t1, NULL);
    return 0;
}

相关推荐：《Linux视频教程》

以上がLinux でスレッド同期を実装するにはいくつかの方法がありますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

全局变量 循环 数据结构 线程 对象 default linux
声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：Linuxのプロセスとプログラムの違いは何ですか次の記事：Linuxのプロセスとプログラムの違いは何ですか

関連記事

続きを見る