无法返回C中线程的调度优先级

Question

我一直在从事一项艰巨的任务，需要进行大量研究，但我已经走进了死胡同。我一直在阅读 Linux 的手册页，但我很难吸收其中的任何信息。这是我使用 C 语言编程的第三周。

我成功创建了一个新线程，并将其调度优先级设置为 SCHED_FIFO。在我的程序中，我创建它，告诉它等待两秒钟，然后一旦完成，我尝试打印出我给它的优先级(所以基本上，我希望它打印出“policy = SCHED_FIFO”)。我还必须为 SCHED_OTHER 执行此操作，但一旦我了解了这一点，我自己就可以轻松完成此操作。

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

void *FIFORunner(void *vargp, pthread_t thread);


int main(){
    pthread_t myThread;
    printf("Before Thread\n\n");

    pthread_create(&myThread, NULL, FIFORunner, NULL);

    pthread_join(myThread, NULL);

    printf("After Thread\n");

    return 0;
} 



void *FIFORunner(void *vargp, pthread_t myThread){

   int s, policy;

   struct sched_param param;

   pthread_setschedparam(&myThread, SCHED_FIFO, &param);

   sleep(2);

   s = pthread_getschedparam(myThread, &policy, &param);

   printf("policy = %d\n", policy);
   return NULL;
}

这就是我的代码，没什么特别的。每当我运行它时，它都会打印出一个看似随机的整数，例如:policy = 1464624896、policy = -1630095616和policy = 1487660800。

如何让 pthread_getschedparam() 工作？我是否传递了错误的内容？

Answer 1

以下建议代码:

1. 干净地编译
2. 执行所需的功能
3. 如果尝试提高优先级或调度级别将会失败
4. 正确检查错误
5. 掌握此基本代码后，您可以尝试提高优先级和/或调度级别。
6. 建议在创建线程时在“attributes”参数中进行优先级和/或调度级别设置，因为在线程内提高这些值不起作用
7. 这是线程函数的语法: void *(*start_routine) (void *) 请注意，只有 1 个参数，而不是两个。因此，OP 发布的代码无法编译。 (这不是唯一的原因)
8. 关于: pthread_setschedparam(&myThread, SCHED_FIFO, ¶m);变量 myThread 是函数 main() 中的局部变量，因此在 main() 范围之外不可见。结果是发布的代码无法编译。
9. 关于: void *FIFORunner(void *vargp) 不使用参数 vargp。这会导致编译器输出警告消息。要消除警告消息，函数中的第一行应为:(void)vargp;
10. 对于两者:pthread_setschedparam(&myThread, SCHED_FIFO, ¶m); 和 s = pthread_getschedparam(myThread, &policy, ¶m); 应检查返回值 (== 0) 确保操作成功。如果不成功，则调用 perror() 输出随附的文本以及系统认为操作失败的原因。
11. 关于:return NULL; 这将“起作用”，但是，位于 pthread 函数系列中的等效语句将是:pthread_exit( NULL ) ;

现在，建议的代码:

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

void *FIFORunner( void *vargp );


int main( void )
{
    pthread_t myThread;
    printf("Before Thread\n\n");

    // any priority and/or scheduling changes should be
    // applied via the second parameter to 'pthread_create()'
    pthread_create( &myThread, NULL, FIFORunner, NULL);

    printf( "in main: myThread = %d\n", (int)myThread );

    pthread_join( myThread, NULL );

    printf("After Thread\n");

    return 0;
}


void *FIFORunner( void *vargp )
{
    (void)vargp;

   pthread_t myThread = pthread_self();

    int policy = SCHED_OTHER;   // any higher policy will cause 'pthread_setschedparam()` to fail.


    struct sched_param param;
    param.sched_priority = 0;   // any higher priority will cause 'pthread_setschedparam()` to fail.


    printf( "in Thread: myThread = %d\n", (int)myThread );
    if( pthread_setschedparam( myThread, policy, &param ) )
    {
        perror( "pthread_setschedparm failed" );
        pthread_exit( NULL );
    }

    sleep(2);

    if( pthread_getschedparam( myThread, &policy, &param ) )
    {
        perror( "pthread_getschedparam failed" );
        pthread_exit( NULL );
    }

    printf( "policy = %d\n", policy );
    pthread_exit( NULL );
}