C中的循环调度程序

Question

我需要一些循环调度程序的帮助。它旨在获取外部 C 文件并将它们放入队列中，同时显示其当前状态，并通过轮循机制调度执行它们。这是我到目前为止所拥有的：

#include<pthread.h>
#include<stdio.h>
#include<string.h>
#include<unistd.h>

enum states {running, ready, waiting, idle};

struct process{
    //command to run process
    enum states state;
    int id;

};

struct process procs[5];
int procSize = 5;

void *runProcess(struct process *p)
{
    while(1)
    {
        printf("Process %i is running", p->id);
        sleep(1);
    }
}

void *takeInput(void *vargp)
{
    //print process statuses when 'procs' is entered
    while(1)
    {
        char *str[64];
        fgets(str, 64, stdin);

        if (strcmp(str, "procs"))
        {
            for (int i = 0; i < procSize; i++)
            {
                printf("Process %i: %i\n", procs[i].id, procs[i].state);
            }
        }
    }
}

void *schedule(void *vargp)
{
    struct process p = procs[0];
    if (p.state == idle)
    {
        p.state = ready;
    }
    if (p.state == ready)
    {
        p.state = running;
        pthread_t run;
        pthread_create(&run, NULL, runProcess, &p);
        //pthread_join(run, NULL);
        sleep(5);
        pthread_cancel(run);
        p.state = ready;

        for(int i = procSize - 1; i > 0; i--)
        {
            procs[i-1] = procs[i];
        }
        procs[procSize] = p;
    }
    else if (p.state == waiting)
    {
        for(int i = procSize - 1; i > 0; i--)
        {
            procs[i-1] = procs[i];
        }
        procs[procSize] = p;
    }

}

int main()
{
    for (int i = 0; i < 5; i++)
    {
        struct process p;
        p.state = idle;
        p.id = i;
        procs[i] = p; 
    }

    pthread_t schedulerid;
    pthread_t inputid;

    pthread_create(&schedulerid, NULL, schedule, NULL);
    //pthread_join(schedulerid, NULL);
    pthread_create(&inputid, NULL, takeInput, NULL);
    //pthread_join(inputid, NULL);
}

当我尝试运行它时，我没有收到任何错误，只有警告，没有任何反应。我需要改进什么？尝试使用线程调用函数是否存在问题？任何帮助，不胜感激。

更新时出现警告：

Sched.c:35:20: warning: passing argument 1 of ‘strcmp’ from incompatible pointer type [-Wincompatible-pointer-types]
   35 |         if (strcmp(str, "procs"))
      |                    ^~~
      |                    |
      |                    char **
In file included from Sched.c:3:
/usr/include/string.h:137:32: note: expected ‘const char *’ but argument is of type ‘char **’
  137 | extern int strcmp (const char *__s1, const char *__s2)
      |                    ~~~~~~~~~~~~^~~~
Sched.c: In function ‘schedule’:
Sched.c:56:36: warning: passing argument 3 of ‘pthread_create’ from incompatible pointer type [-Wincompatible-pointer-types]
   56 |         pthread_create(&run, NULL, runProcess, &p);
      |                                    ^~~~~~~~~~
      |                                    |
      |                                    void * (*)(struct process *)
In file included from Sched.c:1:
/usr/include/pthread.h:200:15: note: expected ‘void * (*)(void *)’ but argument is of type ‘void * (*)(struct process *)’
  200 |       void *(*__start_routine) (void *),
      |       ~~~~~~~~^~~~~~~~~~~~~~~~~~~~~~~~~

Answer 1

让我们修复这些警告

    char *str[64];
    fgets(str, 64, stdin);

    if (strcmp(str, "procs"))

应该是

    char str[64];
    fgets(str, 64, stdin);

    if (strcmp(str, "procs"))

然后

    pthread_create(&run, NULL, runProcess, &p);

该函数必须是 void* 函数 （void*）

因此，将运行过程更改为

void *runProcess(void *v)
{
    struct process *p =(struct process*)v;
    while(1)
    {
        printf("Process %i is running", p->id);
        sleep(1);
    }
}

通过一个空洞，把它铸造成你需要的样子

现在编译时没有任何警告。

最后把你的连接放回去

int pt1 = pthread_create(&schedulerid, NULL, schedule, NULL);
int pt2 = pthread_create(&inputid, NULL, takeInput, NULL);
printf("%d %d \n", pt1, pt2);
pthread_join(schedulerid, NULL);
pthread_join(inputid, NULL);

最后一点——您真的必须测试所有系统调用的返回，以确保它们工作正常

它在这里运行

pm100@paul-think:~/ut$ gcc ggg.c -g -lpthread
pm100@paul-think:~/ut$ ./a.out
Process 0 is running