Pthread調度策略和優先級

Question

當所有四個線程都在等待時，我有四個線程正在等待條件變量和第五個線程帖子條件變量。當我將線程優先級設置爲最大值99時，線程切換需要很多時間，這遠遠不能接受。任何人都可以看看並告訴發生了什麼？

#define N_WORK_THREADS  4 
pthread_mutex_t count_mutex  = PTHREAD_MUTEX_INITIALIZER; 
pthread_cond_t condition_var = PTHREAD_COND_INITIALIZER; 

void *functionCount1(void * arg); 
void *functionCount2(void * arg); 

int count = 0; 
int valid = 0; 
int thread_personal[N_WORK_THREADS]; 

static int display_thread_sched_attr(int id) 
{ 
    int policy, s; 
    struct sched_param param; 

    s = pthread_getschedparam(pthread_self(), &policy, &param); 
    if (s != 0) { printf("pthread_getschedparam"); return 1; } 

    printf("Thread Id=%d policy=%s, priority=%d\n",id, 
      (policy == SCHED_FIFO) ? "SCHED_FIFO" : (policy == SCHED_RR) ? "SCHED_RR" : (policy == SCHED_OTHER) ? "SCHED_OTHER" : "???", 
      param.sched_priority); 

    return 0; 
} 


int main(void) 
{ 
    pthread_t  thread_work[N_WORK_THREADS]; 
    pthread_t  thread; 
    int    i,s; 
    pthread_attr_t attr; 
    struct   sched_param param; 

    s = pthread_attr_init(&attr); 
    if (s != 0) { printf("pthread_attr_init"); return 1; } 

    s = pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED); 
    if (s != 0) { printf("pthread_attr_setinheritsched"); return 1; } 

    s = pthread_attr_setschedpolicy(&attr, SCHED_RR); 
    if (s != 0) { printf("pthread_attr_setschedpolicy"); return 1; } 

    param.sched_priority = 99; 
    s = pthread_attr_setschedparam(&attr, &param); 
    if (s != 0) { printf("pthread_attr_setschedparam"); return 1; } 

    for (i=0; i<N_WORK_THREADS; i++) { thread_personal[i] = 0; } 

    for (i=0; i<N_WORK_THREADS; i++) { pthread_create(&thread_work[i], &attr, &functionCount1, (void *)i); } 

    param.sched_priority = 99; 
    s = pthread_attr_setschedparam(&attr, &param); 
    if (s != 0) { printf("pthread_attr_setschedparam"); return 1; } 
    pthread_create(&thread, &attr, &functionCount2, (void *)N_WORK_THREADS); 

    for (i=0; i<N_WORK_THREADS; i++) { pthread_join(thread_work[i], NULL); } 
    pthread_join(thread, NULL); 

    for (i=0; i<N_WORK_THREADS; i++) { printf("Thread Id=%d Mutex USed=%d\n",i,thread_personal[i]); } 

    exit(EXIT_SUCCESS); 
} 

void *functionCount1(void * arg) 
{ 
    int i; 
    int id = (int) arg; 

    display_thread_sched_attr(id); 

    for(i=0; i<10; i++) 
    { 
    pthread_mutex_lock(&count_mutex); 

    thread_personal[id] += 1; 

    while (((count>>id) & 0x1) == 0) 
    { 
     pthread_cond_wait(&condition_var, &count_mutex); 
    } 
    count = count^ (1<<id); 

    printf("Thread Id %d: Valid = %d\n",id,valid); 

    pthread_mutex_unlock(&count_mutex); 
    } 

    return NULL; 
} 

void *functionCount2(void * arg) 
{ 
    int check; 
    int id = (int) arg; 

    display_thread_sched_attr(id); 

    check =0; 
    while (check < 10) 
    {  
    pthread_mutex_lock(&count_mutex); 

    if (count == 0) 
    { 
     pthread_cond_broadcast (&condition_var); 
     count =0xF; 
     printf("Thread Id %d: Counter = %d\n",id,check); 
     valid = check++; 
    } 

    pthread_mutex_unlock(&count_mutex); 
    } 
    return NULL; 
} 

Answer 1

我無法啓用，因爲程序根本就不時在那裏（我在評論提到工作的調度策略代碼來測試你的程序：用gcc 4.8的Linux 3.16.0 x86_64的。 4）。

，但我想，你的問題可能是由於在functionCount2()循環：

while (check < 10) 
{  
    pthread_mutex_lock(&count_mutex); 

    if (count == 0) 
    { 
     pthread_cond_broadcast (&condition_var); 
     count =0xF; 
     printf("Thread Id %d: Counter = %d\n",id,check); 
     valid = check++; 
    } 

    pthread_mutex_unlock(&count_mutex); 
} 

一般來說，互斥對象的並行線程收購不能保證公平或FIFO（不過說實話，我不確定線程​​調度策略如何影響它）。我相信發生的事情是這個循環釋放count_mutex然後立即重新獲得它，即使其他線程被阻塞等待聲明互斥體。隨着調度策略的實施，這可能會發生，直到線程使用其量子。