与 C 中的循环 sigwait 并行测量时间

如何解决与 C 中的循环 sigwait 并行测量时间

我有一个向孩子们发送信号的主要过程，如下所示：

void handleInputs(query_data *q_data)
{
    char input[DEFAULT_INPUT_SIZE];
    while(1)
    {

        if(fgets(input,DEFAULT_INPUT_SIZE,stdin)==NULL) ERR("fgetS");
        input[strlen(input)-1] = '\0';
        if(!strcmp(input,"exit"))
        {
            kill(0,SIGTERM);
            exit(EXIT_SUCCESS);
        }
        else if(!strcmp(input,"index"))
            kill(0,SIGUSR2);

        else if(!strcmp(input,"status"))
            kill(0,SIGUSR1);    
        else
        {
            char* token = strtok(input," ");
            if(!token) printf("Wrong input\n");
            else
            {
                if(!strcmp(token,"query"))
                {
                    initializeQueryNumbers(q_data,token);
                    createqueryThread(q_data);
                }
                else printf("Wrong input\n");
            }
            
        }   
    }
}

然后我有一个子进程在这样的循环中使用 sigwait 等待信号：

void waitForSignals(data* ch_data)
{
   
    char* pid_directory = strConcat(ch_data->dir,"/.numf_pid");
    int signo;
    for(;;)
    {
        //how to make this block independent to the sigwait
        printf("time elapse: %ld  interval: %d\n",time(NULL)-ch_data->end,ch_data->i);
        if((time(NULL)- ch_data->end)>ch_data->i && ch_data->status ==0)
        {
            printf("Time elapsed from the last indexing > %d\n",ch_data->i);
            createIndexingThread(ch_data);
        }
       //end here

        if(sigwait(&(ch_data->mask),&signo)) ERR("SIGWAIT");
        switch(signo)
        {
            case SIGUSR1:
                if(ch_data->status == 1)
                {
                    printf("Indexing in progress for directory: %s\n",ch_data->dir);
                    printf("Time elapsed: %ld\n",time(NULL)- ch_data->start);
                }
                else printf("No indexing in progress for directory: %s\n",ch_data->dir);
                break;
            case SIGUSR2:
                if(ch_data->status ==0) 
                    createIndexingThread(ch_data);
                else printf("Indexing already in progess for directory: %s\n",ch_data->dir);
                break;
            case SIGTERM:
                if(remove(pid_directory)<0) ERR("REMOVE");
                free(pid_directory);
                if(pthread_cancel(ch_data->tid)==0)
                    printf("Stopped the indexing of directory %s\n",ch_data->dir);
                exit(EXIT_SUCCESS);
        }

        
    }
    if(pthread_join(ch_data->tid,NULL)) ERR("PTHREAD_JOIN");
}

我的子进程创建了一些索引的线程。当从主进程发出 SIGUSR2 信号时（工作正常）或上次索引经过的时间大于某个用户给定的时间（存储在 ch_data->i 中）时，我想创建这样的线程。然而，现在评论之间的块只有在我从主进程发送一些信号后才活跃起来。使其并行工作的最佳方法是什么？

解决方法

如果我理解正确，您是在问如何安排线程操作根据信号或自最近一次操作以来的时间过去，以先到者为准。

您可以使用 sigtimedwait(interesting_sigs,NULL,timeout) 而不是 sigwait，根据需要重新计算您的超时。

您可能会arm a POSIX timer 启动操作（或者，可能是向自己发出信号）。您需要检查该操作是否最近没有执行过，并且您需要适当地重新准备（重新安排）下一个计时器，可能是在每次操作结束时。

您可能只有一个空闲循环后台线程来执行计时器的工作。有时这些比 sigevent 计时器更容易推理。

您可能会合并一个事件驱动的框架，例如 libevent，它知道如何处理超时和信号，而不必担心实现。不过，您可能仍需要重新计算到期时间。