- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我一直在尝试编写一个程序,使用线程和信号量模拟最短优先作业算法。当主线程告诉他这样做时,每个线程都有责任打印其ID。主线程(主)将控制这些作业的时间打印在屏幕上。以下是我想到的,但我似乎做错了一些我还无法弄清楚的事情。我设法让它打印出相应的作业,但总是有 10 个作业中缺少 2 个。文件格式是“id(char)arrival(int)burst(int)”。所以我在这里迫切需要帮助,因为我有尝试了很多事情,但总是在几个小时内陷入同样的情况。
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
#include <stdlib.h>
#define MAX 10
sem_t childs[MAX];
sem_t master;
int jobdone = 0;
typedef struct job
{
int burst, arrival, wait_time, turn_around, executed, done;
char id;
} JOB;
JOB jobs[MAX];
void ShortestFirstJob()
{
int i, j;
char id;
int burst, arrival, wait_time, turn_around, done;
for (i = 0; i < MAX; i++)
{
for (j = 0; j < MAX - 1; j++)
{
if (jobs[j].arrival > jobs[j + 1].arrival)
{
id = jobs[j].id;
done = jobs[j].done;
burst = jobs[j].burst;
arrival = jobs[j].arrival;
wait_time = jobs[j].wait_time;
turn_around = jobs[j].turn_around;
jobs[j].id = jobs[j + 1].id;
jobs[j].burst = jobs[j + 1].burst;
jobs[j].wait_time = jobs[j + 1].wait_time;
jobs[j].arrival = jobs[j + 1].arrival;
jobs[j].turn_around = jobs[j + 1].turn_around;
jobs[j].done = jobs[j + 1].done;
jobs[j + 1].id = id;
jobs[j + 1].burst = burst;
jobs[j + 1].arrival = arrival;
jobs[j + 1].wait_time = wait_time;
jobs[j + 1].turn_around = turn_around;
jobs[j + 1].done = done;
}
}
}
printf("SORT \n");
for (j = 0; j < MAX; j++)
{
printf("%c %d %d\n", jobs[j].id, jobs[j].arrival, jobs[j].burst);
}
}
void* PrintJob(void *params)
{
char id = *((char*) params);
int i, j, k;
for (i = 0; i < MAX; i++)
{
if (id == jobs[i].id)
break;
}
for (k = 0; k < jobs[i].burst; k++)
{
sem_wait(&childs[i]);
printf("%c", id);
fflush(stdout);
jobs[i].executed += 1;
for (j = 0; j < MAX; j++)
{
if ((i != j) && (jobs[j].arrival > 0))
{
jobs[j].arrival -= 1;
jobs[j].wait_time += 1;
}
}
sem_post(&master);
}
jobs[i].done = 1;
jobdone++;
}
int main()
{
pthread_t threadIds[MAX];
char threadsIdx;
int result;
int i = 0;
int j;
int index[MAX];
FILE* fp = fopen("joblist1.txt", "r");
for (j = 0; j < MAX; j++)
{
sem_init(&childs[j], 0, 0);
}
sem_init(&master, 0, 1);
char id;
int arrival, burst;
while (fscanf(fp, "%c %d %d\n", &id, &arrival, &burst) != EOF)
{
jobs[i].id = id;
jobs[i].arrival = arrival;
jobs[i].burst = burst;
jobs[i].wait_time = 0;
jobs[i].turn_around = 0;
jobs[i].executed = 0;
jobs[i].done = 0;
i++;
}
for (j = 0; j < MAX; j++)
{
printf("%c %d %d\n", jobs[j].id, jobs[j].arrival, jobs[j].burst);
}
ShortestFirstJob();
for (i = 0; i < MAX; i++)
{
if (pthread_create(&threadIds[i], NULL, PrintJob, &jobs[i].id) != 0)
{
perror("thread create");
exit(1);
}
}
int k, c = 0;
int min = 0;
int in = 0;
int value, flag = 0;
while (jobdone < MAX)
{
k = 0;
c = 0;
sem_wait(&master);
for (j = 0; j < MAX; j++)
{
if ((jobs[j].arrival == 0) && (jobs[j].done != 1))
{
index[k++] = j;
c++;
}
}
if (c == 1)
{
sem_post(&childs[index[0]]);
}
else if (c > 1)
{
min = jobs[index[0]].burst;
for (j = 1; j < k; j++)
{
if (jobs[index[j]].burst <= min)
{
min = jobs[index[j]].burst;
in = index[j];
}
}
sem_post(&childs[in]);
}
}
for (i = 0; i < MAX; i++)
{
pthread_join(threadIds[i], NULL );
}
return 0;
}
最佳答案
我不太理解你的一些计算,但我发现了两个问题。
首先,在函数PrintJob()
中,您应该在发布主信号量之前设置jobs[i].done = 1;
,因为主线程评估jobs[i].done
来决定唤醒哪个线程。
因此 PrintJob()
函数的正确代码应该是:
void* PrintJob(void *params) {
char id = *((char*) params);
int i, j, k;
for (i = 0; i < MAX; i++) {
if (id == jobs[i].id) break;
}
for (k = 0; k < jobs[i].burst; k++) {
sem_wait(&childs[i]);
printf("%c", id);
fflush(stdout);
jobs[i].executed += 1;
for (j = 0; j < MAX; j++)
{
if ((i != j) && (jobs[j].arrival > 0))
{
jobs[j].arrival -= 1;
jobs[j].wait_time += 1;
}
}
/////////////////////////////
// Here:
if(k == (jobs[i].burst - 1))
jobs[i].done = 1;
jobdone++;
}
/////////////////////////////
sem_post(&master);
}
}
第二个问题出现在主线程中。我不知道到底是什么问题,但是当我测试你的程序时,问题就在这里,主线程试图唤醒一个已完成的线程,该线程具有 jobs[index[j]].done
设置为1
。我不确定这是主要问题,但当 jobs[index[0]].burst
为最小值时,您似乎忘记给 in
赋值。所以正确的代码应该是:
else if (c > 1) {
min = jobs[index[0]].burst;
// Here:
in = index[0];
for (j = 1; j < k; j++)
{
if (jobs[index[j]].burst <= min)
{
min = jobs[index[j]].burst;
in = index[j];
}
}
sem_post(&childs[in]);
}
关于c - 信号量无法正常工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43823746/
所以我目前正在研究 C 中的 POSIX 线程和信号编程。我的讲师使用 sigset(int sigNumber, void* signalHandlerFUnction) 因为他的笔记不是世界上最好
我正在制作一个 C++ 游戏,它要求我将 36 个数字初始化为一个 vector 。你不能用初始化列表初始化一个 vector ,所以我创建了一个 while 循环来更快地初始化它。我想让它把每个数字
我正在尝试让 Python 发送 EOF信号 (Ctrl+D) 通过 Popen() .不幸的是,我找不到任何关于 Popen() 的引用资料。 *nix 类系统上的信号。这里有谁知道如何发送 EOF
我正在尝试让 Python 发送 EOF信号 (Ctrl+D) 通过 Popen() .不幸的是,我找不到任何关于 Popen() 的引用资料。 *nix 类系统上的信号。这里有谁知道如何发送 EOF
我正在学习编码并拥有一个实时的 Django 项目来保持我的动力。在我的 Django 应用程序中,用户留下评论,而其他人则回复所述评论。 每次用户刷新他们的主页时,我都会计算他们是否收到了关于他们之
登录功能中的django信号有什么用?用户已添加到请求 session 表中。那么 Django auth.login 函数中对信号的最后一行调用是什么? @sensitive_post_param
我已经将用户的创建与函数 create_user_profile 连接起来,当我创建我的用户时出现问题,我似乎连接的函数被调用了两次,而 UserProfile 试图被创建两次,女巫触发了一个错误 列
我有一个来自生产者对象处理的硬件的实时数据流。这会连接到一个消费者,该消费者在自己的线程中处理它以保持 gui 响应。 mainwindow::startProcessing(){ QObje
在我的 iPhone 应用程序中,我想提供某种应用程序终止处理程序,该处理程序将在应用程序终止之前执行一些最终工作(删除一些敏感数据)。 我想尽可能多地处理终止情况: 1) 用户终止应用 2) 设备电
我试图了解使用 Angular Signals 的优势。许多解释中都给出了计数示例,但我试图理解的是,与我下面通过变量 myCount 和 myCountDouble 所做的方式相比,以这种方式使用信
我对 dispatch_uid 的用法有疑问为信号。 目前,我通过简单地添加 if not instance.order_reference 来防止信号的多次使用。 .我现在想知道是否dispatch
有时 django 中的信号会被触发两次。在文档中,它说创建(唯一)dispatch_uid 的一个好方法是模块的路径或名称[1] 或任何可哈希对象的 ID[2]。 今天我尝试了这个: import
我有一个用户定义的 shell 项目,我试图在其中实现 cat 命令,但允许用户单击 CTRL-/ 以显示下一个 x 行。我对信号很陌生,所以我认为我在某个地方有一些语法错误...... 主要...
http://codepad.org/rHIKj7Cd (不是全部代码) 我想要完成的任务是, parent 在共享内存中写入一些内容,然后 child 做出相应的 react ,并每五秒写回一些内容
有没有一种方法可以找到 Qt 应用程序中信号/槽连接的总数有人向我推荐 Gamma 射线,但有没有更简单的解决方案? 最佳答案 检查 Qt::UniqueConnection . This is a
我正在实现一个信号/插槽框架,并且到了我希望它是线程安全的地步。我已经从 Boost 邮件列表中获得了很多支持,但由于这与 boost 无关,我将在这里提出我的未决问题。 什么时候信号/槽实现(或任何
在我的代码中,我在循环内创建相同类型的新对象并将信号连接到对象槽。这是我的试用版。 A * a; QList aList; int aCounter = 0; while(aCounter aLis
我知道 UNIX 上的 C 有 signal() 可以在某些操作后调用某些函数。我在 Windows 上需要它。我发现了,它存在什么 from here .但是我不明白如何正确使用它。 我在 UNIX
目前我正在将控制台 C++ 项目移植到 Qt。关于移植,我有一些问题。现在我的项目调整如下我有一个派生自 QWidget 的 Form 类,它使用派生自 QObject 的其他类。 现在请告诉我我是否
在我的 Qt 多线程程序中,我想实现一个基于 QObject 的基类,以便从它派生的每个类都可以使用它的信号和槽(例如抛出错误)。 我实现了 MyQObject : public QObject{..
我是一名优秀的程序员,十分优秀!