从主线程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); 
    }
}