我是线程编程的新手。所以我为这个看似愚蠢的问题道歉。
我正在尝试使用 pthread_attr_t 使用 pthread_create() 创建一个 POSIX 线程。我正在尝试设置 sched_priority 值并将其放入属性中。代码粘贴在下面:
#include <iostream>
#include <cstring>
#include <pthread.h>
using namespace std;
void* log(void* arg)
{
FILE *fp = fopen("/tmp/log.txt", "w+");
if (fp != NULL)
{
fputs("Logging with Thread", fp);
}
else
{
cout <<"file pointer not created" << endl;
}
return 0;
}
int main(int argc, char** argv )
{
pthread_t th;
pthread_attr_t th_attr;
int policy;
struct sched_param thparam;
memset(&thparam, 0,sizeof(sched_param));
int retval = pthread_attr_init(&th_attr);
if (0 != retval)
{
cout <<"Attribute initialization failed" << endl;
}
thparam.sched_priority = 10;
int ret1 = pthread_attr_setschedparam(&th_attr, &thparam);
if (0 == ret1)
{
cout <<"pthread_attr_setschedparam PASSED" << endl;
}
int ret = pthread_create(&th, &th_attr, log, NULL);
if (0 != ret)
{
cout <<"thread not created" << endl;
}
else
{
cout <<"Thread created" << endl;
}
int retval1 = pthread_getschedparam(th, &policy, &thparam);
if (0 != retval1)
{
cout <<"Inside Main::pthread_getschedparam FAILED at start" << endl;
}
else
{
cout <<"Inside Main::priority: " << thparam.sched_priority << endl;
cout <<"Inside Main::sched policy: " << policy << endl;
}
pthread_join(th, NULL);
return (0);
}
每次我运行这个程序时,都会创建线程,但默认优先级(在我的例子中是 15)。由于我已将优先级设置为 10,它应该以 10 优先级开始。我不明白为什么会这样。我打印的所有日志消息都符合预期,似乎没有错误。谁能指出我在代码中做错了什么?
谢谢!!!!
编辑:
我似乎发现了一件有趣的事情。我无法在线程创建期间设置线程优先级。但是我可以在创建线程后更改线程的优先级。我使用 APIpthread_setschedparam
来设置优先级。这次线程的优先级正确地改变了。仍然无法理解为什么会这样。
我还应该提到我正在使用带有 ARM arch 的嵌入式系统。我还将调度程序策略设置为 SCHED_RR。
有人可以解释为什么会这样吗?