用pthreads模拟循环赛

任务是让5个线程同时出现，并且用户分配每个突发时间。然后使用量程为2的循环算法来调度线程。举例来说，如果我有用pthreads模拟循环赛

$ ./m 1 2 3 4 5

运行程序的输出应该

A 1 
B 2 
C 2 
D 2 
E 2 
C 1 
D 2 
E 2 
E 1

但现在我的输出仅显示

A 1 
B 2 
C 2

由于程序犯错其中一个线程不结束暂时，我认为问题是这个线程不能解锁让下一个线程抢锁。我的睡眠（）也不起作用。但我不知道如何修改我的代码以修复它们。我的代码如下：

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 
double times[5]; 
char process[] = {'A', 'B', 'C', 'D', 'E'}; 
int turn = 0; 

void StartNext(int tid)  //choose the next thread to run 
{ 
    int i; 
    for(i = (tid + 1) % 5; times[i] == 0; i = (i + 1) % 5) 
     if(i == tid) //if every thread has finished 
      return; 
    turn = i; 
} 

void *Run(void *tid) //the thread function 
{ 
    int i = (int)tid; 
    while(times[i] != 0) 
    { 
     while(turn != i); //busy waiting till it is its turn 
     if(times[i] > 2) 
     { 
      printf("%c 2\n", process[i]); 
      sleep(2); //sleep is to simulate the actual running time 
      times[i] -= 2; 
     } 
     else if(times[i] > 0 && times[i] <= 2)  //this thread will have finished after this turn 
     { 
      printf("%c %lf\n", process[i], times[i]); 
      sleep(times[i]); 
      times[i] = 0; 
     } 
     StartNext(i); //choose the next thread to run 
    } 
    pthread_exit(0); 
} 

int main(int argc, char **argv) 
{ 
    pthread_t threads[5]; 
    int i, status; 

    if(argc == 6) 
    { 
     for(i = 0; i < 5; i++) 
      times[i] = atof(argv[i + 1]); //input the burst time of each thread 
     for(i = 0; i < 5; i++) 
     { 
      status = pthread_create(&threads[i], NULL, Run, (void *)i); //Create threads 
      if(status != 0) 
      { 
       printf("While creating thread %d, pthread_create returned error code %d\n", i, status); 
       exit(-1); 
      } 
      pthread_join(threads[i], 0); //Join threads 
     } 
    } 
    return 0; 
}

该程序可直接运行。任何人都可以帮我弄明白吗？谢谢！

来源

2012-03-25 goldfrapp04

有些事情我已经想通了阅读你的代码：

~~1.在运行函数的开始，您将TID（这是无效的指针）直接为int。你不应该解除引用吗？~~

最好让int turn易变，这样编译器就不会对它的值做任何假设而不会改变。
当您第二次调用函数sleep时，会传递一个类型为double的参数（times [i]），并且应该传递一个unsigned int参数。像(unsigned int) times[i]这样的直接投射应该可以解决这个问题。
你正在做pthread_join 之前创建其他线程。当你创建线程3时，它进入忙碌的等待状态，其他线程将不会被创建。尝试在for块之后加入连接。

来源

2012-03-25 22:17:19 Castilho

谢谢。根据你的第一点，我不太了解如何修改我的代码。它仍然不能解决问题......在我的例子中，实际创建了突发时间'4'的线程？ – goldfrapp04 2012-03-25 22:53:27

第一点你是对的，你直接将int嵌入指针，我没有看到。但是那里可能有问题，是的，在创建线程时，我会回答问题的答案。 – Castilho 2012-03-25 23:05:14

谢谢！我应该已经意识到“加入”问题。现在它是固定的，谢谢:)最后一个问题：什么是“连接”功能真的在这里做？如果我删除这一行，该程序不起作用，但为什么？ – goldfrapp04 2012-03-25 23:12:19

用pthreads模拟循环赛

回答

相关问题