Paris7/work-stealing-scheduler
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix errors

Browse source
This commit is contained in:
Mylloon 2024-04-23 12:21:10 +02:00
parent dab0c3a30e
commit 83295f16ca
Signed by: Anri
GPG key ID: A82D63DFF8D1317F
1 changed files with 22 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/sched-threads.c
View file

@ -1,12 +1,18 @@
#include "../includes/sched.h" #include "../includes/sched.h"
#include <errno.h>
#include <pthread.h> #include <pthread.h>
#include <stdio.h> #include <stdio.h>
/* Routine d'un thread */
void *sched_worker(void *);
int int
sched_init(int nthreads, int qlen, taskfunc f, void *closure) sched_init(int nthreads, int qlen, taskfunc f, void *closure)
{ {
// Paramètres inutilisés
(void)nthreads;
(void)qlen;
sched_spawn(f, closure, NULL); sched_spawn(f, closure, NULL);
return 0; return 0;
} }
@ -14,21 +20,32 @@ sched_init(int nthreads, int qlen, taskfunc f, void *closure)
int int
sched_spawn(taskfunc f, void *closure, struct scheduler *s) sched_spawn(taskfunc f, void *closure, struct scheduler *s)
{ {
// Paramètres inutilisés
(void)f;
(void)closure;
pthread_t thread; pthread_t thread;
int err; int err;
// Création d'un thread pour la tâche // Création d'un thread pour la tâche
if((err = pthread_create(&thread, NULL, (void *(*)(void *))f, closure)) != if((err = pthread_create(&thread, NULL, sched_worker, &s)) != 0) {
0) { fprintf(stderr, "pthread_create error %d\n", err);
fprintf(stderr, "pthread_create error %d\n", errno);
return -1; return -1;
} }
// Attend la fin du thread // Attend la fin du thread
if((err = pthread_join(thread, NULL)) != 0) { if((err = pthread_join(thread, NULL)) != 0) {
fprintf(stderr, "pthread_join error %d\n", errno); fprintf(stderr, "pthread_join error %d\n", err);
return -1; return -1;
} }
return 0; return 0;
} }
void *
sched_worker(void *arg)
{
(void)arg;
return NULL;
}