C语言 我如何阻止pthread从main打印全局变量,然后继续pthread



我有一个创建pthread的main函数。我正在尝试使用信号量在选择的时间打印一个全局变量(注意-互斥,s1, s2和memoryUsed都全局声明):

int main(int argc, const char * argv[])
{
    pthread_mutex_init(&mutex, NULL);
    sem_init(&s1, 0, 0);
    sem_init(&s2, 0, 0);
    pthread_t t0;
    pthread_create(&t0, NULL, &matrix_management, NULL);
    sem_wait(&s1); // wait for signal from pthread
    printf("Memory Usage from main: %d bytesnn", memoryUsed); // global var
    sem_post(&s2); // signal pthread to continue
    pthread_join(t0, NULL);
    sem_destroy(&s1);
    sem_destroy(&s2);
    pthread_mutex_destroy(&mutex);
    return 0;
}

在我的目标函数中,我想在一个选择点停止并从main中打印一个全局变量。注意,变量是在目标函数中改变的。打印之后,我想继续执行目标函数:

void *matrix_management(void *len)
{
    pthread_mutex_lock(&mutex);
    // CHANGE GLOBAL VAR
    memoryUsed = 1;
    sem_post(&s1); // print from main
    sem_wait(&s2); // wait for signal
    // continue thread...

    pthread_mutex_unlock(&mutex);
    return NULL;
}

然而,主线程似乎根本没有等待来自pthread的信号。它立即打印其全局变量的值。如果我注释掉pthread中的信号,程序就不会死锁。你能像这样在主线程和pthread之间使用信号量吗?

根据您的平台,可能不支持未命名的信号量。在这种情况下,下面的方法可以工作,不过您可能希望创建临时名称,并在以后的解除链接中使用它们。我熟悉这一点的唯一原因是因为我通常工作的平台OS X在10.8.3之前不支持未命名的信号量,因此无错误检查我在代码中看到类似的行为,因为所有的信号量api都失败了。

希望有帮助。

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>
#include <assert.h>
sem_t* s1=NULL, *s2=NULL;
int memoryUsed = 0;
void *matrix_management(void *len)
{
    // CHANGE GLOBAL VAR
    memoryUsed = 1;
    sem_post(s1); // print from main
    sem_wait(s2); // wait for signal
    printf("Thread woken up.n");
    // continue thread...
    return NULL;
}
int main(int argc, const char * argv[])
{
    s1 = sem_open("s1", O_CREAT, S_IRUSR | S_IWUSR, 0);
    s2 = sem_open("s2", O_CREAT, S_IRUSR | S_IWUSR, 0);
    assert(s1 && s2 && "Failed to allocate semaphores.");
    pthread_t t0;
    pthread_create(&t0, NULL, &matrix_management, NULL);
    sem_wait(s1); // wait for signal from pthread
    printf("Memory Usage from main: %d bytes.n", memoryUsed); // global var
    printf("Waking thread...n"); // global var
    sem_post(s2); // signal pthread to continue
    pthread_join(t0, NULL);
    printf("Thread finishedn");
    sem_close(s1);
    sem_close(s2);
    sem_unlink("s1");
    sem_unlink("s2");
    return 0;
}

Memory Usage from main: 1 bytes.
Waking thread...
Thread woken up.
Thread finished

最新更新