c++ - 从主线程 C++ 更新信号量

Question

我正在玩弄信号量并让自己陷入这个问题。我想要做的是从主线程更新 pthread 内的信号量。我创建了 struct，将带有该结构的 semaphore 传递给 pthread，并在另一个函数中使用该结构来执行 sem_post。但是下面的代码不起作用。似乎我传递给 pthread 的信号量和我在 start 函数中使用的信号量不同。有很多示例可以全局创建信号量并在线程中使用。但是我想在本地创建信号量，这样如果需要的话，我可以创建多个信号量和多个线程来同步。我应该如何处理这个问题？

#include <iostream> 
#include <semaphore.h> 
#include <pthread.h> 
#include <signal.h>
#include "unistd.h"

using namespace std; 

class m { 
    public: 
        struct my_sem { 
            sem_t sem_lock; 
        };  
        m(); 
        ~m(); 

        void create_threads(); 
        void start(my_sem*); 
        static void *hello(void *);  
}; 

m::m() { 
    create_threads(); 
} 

m::~m() {}

void m::create_threads() { 
    pthread_t t1, t2; 
    sem_t s; 

    sem_init(&s, 0, 0); 

    my_sem *sem1 = new my_sem; 
    sem1->sem_lock = s; 

    pthread_create(&t1, null, hello, sem1); 
    start(sem1); 
} 

void *m::hello(void *arg) { 
    my_sem* a = (my_sem*)arg; 
    sem_t t = a->sem_lock; 

    while(1) { 
        sem_wait(&t); 
        cout << "hello" << endl; 
    } 
} 

void m::start(my_sem* s) { 
    sem_t h = s->sem_lock; 
    while(1) { 
        sleep(10); 
        sem_post(&h); 
    } 
} 

int main() { 

    m m;     
    return 0; 
} 

我期望的输出是:

HELLO 
<wait 10 seconds> 
HELLO 
<wait 10 seconds> 
.
.
.

Answer 1

您不要复制信号量，因为它们依赖于它们的地址(内存中的位置)。

将一个 sem_t 分配给另一个，将不会在它们之间共享状态。赋值将复制一些值，但您将有两个不同信号量对象。

相反，您创建一个信号量作为某个类的成员并将指针传递给它，如下所示:

void m::create_threads() { 
    pthread_t t1, t2; 

    sem_init(&this->sem.sem_lock, 0, 0); 

    pthread_create(&t1, nullptr, hello, &this->sem); 
    start(&this->sem);
} 

void *m::hello(void *arg) { 
    my_sem* a = (my_sem*)arg; 

    while(1) { 
        sem_wait(&a->sem_lock); 
        cout << "hello" << endl; 
    } 
} 

void m::start(my_sem* s) { 
    while(1) { 
        sleep(1); 
        sem_post(&s->sem_lock); 
    }
}