线程中while和for的强占性问题

kingstarlcq

thread1{
while(K<20){
lock();

k++;

unlock();}
}

thread2{
for(k=0;k<20;K++)
{lock();
unlock();
;
}


分别创建多个thread1和thread2，就是多个线程调用相同函数(在不同的程序中)，调用thread1的程序多个线程会交互运行（就是k不到20的时候会跳到别的线程），而调用thread2的程序的多个线程总是每个线程运行完后再运行下一个线程（就是每个线程到20后再跑下一个）
为什么会出现这种情况，是应为  while的抢占性强一点而for的抢占性弱一点还是别的原因，网上搜了半天也没找到原应。

alexhappy

这个是操作系统调度算法的原因，哪里会有什么while和for的强占性的问题，闻所未温

kingstarlcq

能详细讲解一下么，我看到现在os的调度算法中好像没有类似的情况么

aaaaa5aa

应该是随机的吧,每次系统要操作的都不一样

思一克

while的k++在中间，for的在末尾，有区别。

kingstarlcq

while代码
#include <stdio.h>
#include <pthread.h>
#include<semaphore.h>

#define SIZE 20
int ProductID=0;      
int ConsumeID=0;      
int in = 0;      
int out = 0;  
int buffer[SIZE];
int j=0;
int k=0;  
        
pthread_mutex_t mutex;        
sem_t empty;      
sem_t full;      
pthread_t producerID[5];
pthread_t consumerID[5];      

void *producer(void* ID)
{
       while(j<26){
           sem_wait(&empty);
           pthread_mutex_lock(&mutex);

    printf("producerID:");
       printf("%s\n", ID);
       printf("ProductID:");
       printf("%d\n", ++ProductID);
        
    int i;
       printf("in:");
       printf("%d\n",in);

         if(ProductID==21)
           ProductID=1;
            
       buffer[in] = ProductID;
       in = (in+1)%SIZE;
           j++;
      
       for(i=0;i<SIZE;i++)
      {
         printf(" %d",buffer);
        
       }
printf("\n");
         
           pthread_mutex_unlock(&mutex);
           sem_post(&full);
           sleep(3);
       }
}



void  *consumer(void* ID)
{
       while(k<26){
           sem_wait(&full);
           pthread_mutex_lock(&mutex);

           int i;
           printf("consumerID:");
           printf("%s\n",ID);
           printf("out:");
           printf("%d\n",out);
           ConsumeID = buffer[out];
           buffer[out]=0;
           out = (out+1)%SIZE;
           printf("ConsumeID:");
           printf("%d\n", ConsumeID);
             k++;
      
       for(i=0;i<SIZE;i++)
      {
         printf(" %d",buffer);
        
       }
printf("\n");
         
           pthread_mutex_unlock(&mutex);
           sem_post(&empty);
           sleep(3);
       }
}
int main()
{
char a[10][3]={"p1","p2","p3","p4","p5","c1","c2","c3","c4","c5"};
int i;
sem_init(&empty,0,20);
sem_init(&full,0,0);

for(i=0;i<5;i++)  
{
  pthread_create(&producerID,NULL,&producer,a);      
}  
for(i=0;i<5;i++)  
{   
  pthread_create(&consumerID,NULL,&consumer,a[i+5]);
}      
for(i=0;i<5;i++)
{
  pthread_join(producerID,NULL);
pthread_join(consumerID,NULL);
}
return 0;
}

for代码
#include <stdio.h>
#include <pthread.h>
#include<semaphore.h>

#define SIZE 20
int ProductID=0;      
int ConsumeID=0;      
int in = 0;      
int out = 0;  
int buffer[SIZE];
int j=0;
int k=0;  
        
pthread_mutex_t mutex;        
sem_t empty;      
sem_t full;      
pthread_t producerID[5];
pthread_t consumerID[5];      

void *producer(void* ID)
{
       for(j=0;j<26;j++){
           sem_wait(&empty);
           pthread_mutex_lock(&mutex);

    printf("producerID:");
       printf("%s\n", ID);
       printf("ProductID:");
       printf("%d\n", ++ProductID);
        
    int i;
       printf("in:");
       printf("%d\n",in);

         if(ProductID==21)
           ProductID=1;
            
       buffer[in] = ProductID;
       in = (in+1)%SIZE;
         
      
       for(i=0;i<SIZE;i++)
      {
         printf(" %d",buffer);
        
       }
printf("\n");
         
           pthread_mutex_unlock(&mutex);
           sem_post(&full);
           sleep(3);
       }
}



void  *consumer(void* ID)
{
       for(k=0;k<26;k++){
           sem_wait(&full);
           pthread_mutex_lock(&mutex);

           int i;
           printf("consumerID:");
           printf("%s\n",ID);
           printf("out:");
           printf("%d\n",out);
           ConsumeID = buffer[out];
           buffer[out]=0;
           out = (out+1)%SIZE;
           printf("ConsumeID:");
           printf("%d\n", ConsumeID);
            
      
       for(i=0;i<SIZE;i++)
      {
         printf(" %d",buffer);
        
       }
printf("\n");
         
           pthread_mutex_unlock(&mutex);
           sem_post(&empty);
           sleep(3);
       }
}
int main()
{
char a[10][3]={"p1","p2","p3","p4","p5","c1","c2","c3","c4","c5"};
int i;
sem_init(&empty,0,20);
sem_init(&full,0,0);

for(i=0;i<5;i++)  
{
  pthread_create(&producerID,NULL,&producer,a);      
}  
for(i=0;i<5;i++)  
{   
  pthread_create(&consumerID,NULL,&consumer,a[i+5]);
}      
for(i=0;i<5;i++)
{
  pthread_join(producerID,NULL);
pthread_join(consumerID,NULL);
}
return 0;
}

kingstarlcq

可是不管运行多少次，结果是一样的啊，所以我很迷惑

bobozhang

你把k跑到100万呢