任务是同时存在 5 个线程,用户为每个线程分配突发时间。然后使用量程为 2 的循环算法来调度线程。例如,如果我运行程序
$ ./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
由于程序出错,其中一个线程暂时没有结束,我认为问题在于该线程无法解锁以让下一个线程抢到锁。我的 sleep() 也不起作用。但我不知道如何修改我的代码来修复它们。我的代码如下:
#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;
}
程序可以直接运行。谁能帮我弄清楚吗?谢谢!
最佳答案
阅读您的代码后我发现了一些事情:
<罢工>1。在 Run 函数的开头,将 tid (指向 void 的指针)直接转换为 int。你不应该取消引用它吗?
最好让 int 变成 volatile,这样编译器就不会对其值不变做出任何假设。
当你第二次调用 sleep 函数时,你传递了一个 double (times[i]) 类型的参数,并且你应该传递一个 unsigned int 参数。像
(unsigned int) times[i]
这样的直接转换应该可以解决这个问题。您在创建其他线程之前执行pthread_join。当您创建线程 3 时,它进入忙等待状态,其他线程将不会被创建。尝试将连接放在 for block 之后。
关于c - 使用 pthread 模拟循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9864492/