使用Boost在Linux中设置线程优先级

Question

Boost库似乎没有用于设置线程优先级的设备。这是在Linux上使用的最佳代码吗？还是有更好的方法？

boost::thread myThread(MyFunction()); 

struct sched_param param; 
param.sched_priority = 90; 
pthread_attr_setschedparam(myThread.native_handle(), SCHED_RR, &param); 

我没有很多Linux编程经验。

Answer 1

这是我如何做的基本模板，但经过四周搜索后，我发现旁边没有代码示例，所以我猜测判断是否最佳。

问题是，boost :: thread没有一个构造函数，它允许在创建线程时传递pthead属性，所以你必须在线程启动后进行更改。我知道解决这个问题的唯一方法是通过进程/线程计划继承。除非另有指示，否则新线程将继承其创建者的计划/优先级，以便在创建工作线程之前更改当前线程，然后如果需要则更改回来。看起来很尴尬，但它是一种选择。

下面是一个例子的破解，希望能够解释两者。您可能需要根据需要更改策略和优先级，并以根用户身份运行。

请注意您设置优先级的方式。各种限制适用。

#include <iostream> 
#include <boost/thread/thread.hpp> 
#include <unistd.h> 
#include <sched.h> 
#include <cstdio> 


void* threadfunc() 
{ 
    sleep(5); 
} 

void displayAndChange(boost::thread& daThread) 
{ 
    int retcode; 
    int policy; 

    pthread_t threadID = (pthread_t) daThread.native_handle(); 

    struct sched_param param; 

    if ((retcode = pthread_getschedparam(threadID, &policy, &param)) != 0) 
    { 
     errno = retcode; 
     perror("pthread_getschedparam"); 
     exit(EXIT_FAILURE); 
    } 

    std::cout << "INHERITED: "; 
    std::cout << "policy=" << ((policy == SCHED_FIFO) ? "SCHED_FIFO" : 
           (policy == SCHED_RR) ? "SCHED_RR" : 
           (policy == SCHED_OTHER) ? "SCHED_OTHER" : 
                 "???") 
       << ", priority=" << param.sched_priority << std::endl; 


    policy = SCHED_FIFO; 
    param.sched_priority = 4; 

    if ((retcode = pthread_setschedparam(threadID, policy, &param)) != 0) 
    { 
     errno = retcode; 
     perror("pthread_setschedparam"); 
     exit(EXIT_FAILURE); 
    } 

    std::cout << " CHANGED: "; 
    std::cout << "policy=" << ((policy == SCHED_FIFO) ? "SCHED_FIFO" : 
           (policy == SCHED_RR) ? "SCHED_RR" : 
           (policy == SCHED_OTHER) ? "SCHED_OTHER" : 
                  "???") 
       << ", priority=" << param.sched_priority << std::endl; 
} 


int main(int argc, char* argv[]) 
{ 
    int policy, res; 

    struct sched_param param; 

    if ((policy = sched_getscheduler(getpid())) == -1) 
    { 
     perror("sched_getscheduler"); 
     exit(EXIT_FAILURE); 
    } 

    if ((res = sched_getparam(getpid(), &param)) == -1) 
    { 
     perror("sched_getparam"); 
     exit(EXIT_FAILURE); 
    } 

    std::cout << " ORIGINAL: "; 
    std::cout << "policy=" << ((policy == SCHED_FIFO) ? "SCHED_FIFO" : 
           (policy == SCHED_RR) ? "SCHED_RR" : 
           (policy == SCHED_OTHER) ? "SCHED_OTHER" : 
                  "???") 
       << ", priority=" << param.sched_priority << std::endl; 


    policy = SCHED_RR; 
    param.sched_priority = 2; 

    if ((res = sched_setscheduler(getpid(), policy, &param)) == -1) 
    { 
     perror("sched_setscheduler"); 
     exit(EXIT_FAILURE); 
    } 

    boost::thread t1(&threadfunc); 

    displayAndChange(t1); 

    t1.join(); 

    return 0; 
} 

Answer 2

我不认为Linux的真正拥有线程的优先级 - 在大多数内核可以使用“好”的水平，但是这可能是它（这将简化调度） - 然而，并不是所有的Linux系统将尊重那！ （取决于调度程序）。

Answer 3

你可以看看这个库（通过对矿井，尚未公布一个学生写的，看看svn库）： https://sourceforge.net/projects/threadutility/

基本上，他写了升压的包装::线程允许通过根据平台（当前Linux或Windows）选择正确的内部实现来以便携方式指定和设置线程的优先级。在Linux中，代码使用sched_setscheduler（）系统调用。

Answer 4

boost::thread确实能够在调用pthread_create()之前获得pthread属性。它提供的boost::thread::attributes类型本身只能用于设置堆栈大小（在支持它的系统上），但它也提供了一个.get_native_handle()方法，该方法返回一个pthread_attr_t，您可以在其中设置所需的属性。然后，您可以简单地将make_thread()与该boost::thread::attributes对象作为参数。请参阅本节中的第二个和第三个代码框：http://www.boost.org/doc/libs/1_53_0/doc/html/thread/thread_management.html#thread.thread_management.tutorial.attributes