在下面的代码片段中，我创建了6个线程。各有不同的优先级。全局优先级数组中提到了优先级。我正在根据线索索引在每个线程内连续增加全局变量。如果线程优先级更高，我期待计数更高。但我的输出不遵循优先概念pl。请参阅下面显示的输出顺序。我在Ubuntu 16.04和Linux内核4.10上尝试了这一点。Linux线程优先级，行为不正常

O/P,

Thread=0

Thread=3

Thread=2

Thread=5

Thread=1

Thread=4

pid=32155 count=4522138740

pid=32155 count=4509082289

pid=32155 count=4535088439

pid=32155 count=4517943246

pid=32155 count=4522643905

pid=32155 count=4519640181

代码：

#include

#include

#define FAILURE -1

#define MAX_THREADS 15

long int global_count[MAX_THREADS];

/* priority of each thread */

long int priority[]={1,20,40,60,80,99};

void clearGlobalCounts()

{

int i=0;

for(i=0;i

global_count[i]=0;

}

/**

thread parameter is thread index

**/

void funcDoNothing(void *threadArgument)

{

int count=0;

int index = *((int *)threadArgument);

printf("Thread=%d\n",index);

clearGlobalCounts();

while(1)

{

count++;

if(count==100)

{

global_count[index]++;

count=0;

}

}

}

int main()

{

int i=0;

for(int i=0;i

create_thread(funcDoNothing, i,priority[i]);

sleep(3600);

for(i=0;i

{

printf("pid=%d count=%ld\n",getpid(),

global_count[i]);

}

}

create_thread(void *func,int thread_index,int priority)

{

pthread_attr_t attr;

struct sched_param schedParam;

void *pParm=NULL;

int id;

int * index = malloc(sizeof(int));

*index = thread_index;

void *res;

/* Initialize the thread attributes */

if (pthread_attr_init(&attr))

{

printf("Failed to initialize thread attrs\n");

return FAILURE;

}

if(pthread_attr_setschedpolicy(&attr, SCHED_FIFO))

{

printf("Failed to pthread_attr_setschedpolicy\n");

return FAILURE;

}

if (pthread_attr_setschedpolicy(&attr, SCHED_FIFO))

{

printf("Failed to setschedpolicy\n");

return FAILURE;

}

/* Set the capture thread priority */

pthread_attr_getschedparam(&attr, &schedParam);;

schedParam.sched_priority = sched_get_priority_max(SCHED_FIFO) - 1;

schedParam.sched_priority = priority;

if (pthread_attr_setschedparam(&attr, &schedParam))

{

printf("Failed to setschedparam\n");

return FAILURE;

}

pthread_create(&id, &attr, (void *)func, index);

}