0

我正在开发一个使用信号量同时处理相同功能的 c 项目。当我在 linux 上以 root 用户运行它时，它运行良好。但是如果我在另一个用户上运行它，脚本不会被执行，它会在信号量数组中留下一个信号量。有人知道这个问题的解决方案吗？

这是我的代码：

int main(int argC, char* argv[]) {

    pthread_t thr[argC-1];
    int indexes[argC-1];
    int i,j;
    for(j=0; j<(argC-1); j++) {

        indexes[j] = atoi(argv[j+1]);
        pthread_create (&thr[j], NULL, (int *) &stabtest, (void *) &indexes[j]);  
    }

    sem_init(&mutex, 0, 1); 

    for(j=0; j<(argC-1); j++) pthread_join(thr[j], NULL);

    // Destroy semaphore
    sem_destroy(&mutex);

    // Exit
    exit(0);   
}

int stabtest(void *ptr) {

    sem_wait(&mutex); // down semaphore

    // Other code ...

    sem_post(&mutex); // up semaphore 
    pthread_exit(0);  // exit thread 

}

我实际上在互联网上找到了这段代码，因为我没有使用信号量的经验。所以我不确定这段代码是否适合同时并行运行该函数。但它适用于root用户，所以我猜代码或多或少没问题。

谢谢！

4

1 回答 1

0

如果这是您正在使用的代码，那么您认为发生的任何事情都不会发生。权限应该对您正在使用的信号量没有影响。并且没有信号量数组，您使用的是单个信号量。

你似乎对命令行参数有一个不稳定的把握。它们是指向字符串的数组指针。argc 是参数的数量。总会有至少 1 个 argv，argv[0]，也就是程序名。请不要重命名 argc。每个人都知道 argc 是什么。重命名只会惹恼人们。

您启动线程，然后初始化信号量。那是个问题。

pthread 的启动函数必须具有签名void* stabtest(void *ptr)。你是int stabtest(void *ptr)，你正试图摆脱错误。不要那样做。如果你想从一个线程返回一些东西，你可以通过 void ptr 作为pthread_create. 也就是说，分配一些内存，在pthread_create中传递，在线程中做任何你需要改变指向的信息，然后从线程返回相同的void ptr。当您执行此操作时，pthread_join您可以访问返回的指针，该指针指向pthread_join.

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

sem_t mutex;

void* stabtest(void *ptr)
{
    sem_wait(&mutex); // down semaphore
    printf("in thread %lu...\n", pthread_self());
    sem_post(&mutex); // up semaphore

    pthread_exit(0);  // exit thread
}

int main(int argc, char* argv[])
{
    if (argc != 2)
    {
        printf("usage: %s numThread\n", argv[0]);
        exit(1);
    }

    int maxThreads = atoi(argv[1]);

    pthread_t thr[maxThreads];
    int indexes[maxThreads];
    int i, j;

    sem_init(&mutex, 0, 1);

    for (j = 0; j < maxThreads; j++)
        pthread_create (&thr[j], NULL, stabtest, NULL);

    for (j = 0; j < maxThreads; j++)
        pthread_join(thr[j], NULL);

    // Destroy semaphore
    sem_destroy(&mutex);

    // Exit
    exit(0);
}
于 2013-10-06T00:25:56.993 回答