29 lines
828 B
C
29 lines
828 B
C
|
#pragma once
|
|||
|
|
|
|||
|
|
#include <unistd.h>
|
|||
|
|
|
|||
|
|
struct scheduler;
|
|||
|
|
|
|||
|
|
typedef void (*taskfunc)(void *, struct scheduler *);
|
|||
|
|
|
|||
|
|
static inline int sched_default_threads() {
|
|||
|
|
return sysconf(_SC_NPROCESSORS_ONLN);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/* Lance l'ordonnanceur
|
|||
|
|
* - nthreads : nombre de threads créer par l'ordonnanceur
|
|||
|
|
* Si 0, le nombre de threads sera égal au nombre de coeurs de votre machine
|
|||
|
|
*
|
|||
|
|
* - qlen : nombre minimum de tâches simultanées que l’ordonnanceur devra
|
|||
|
|
* supporter
|
|||
|
|
* Retourne une erreur si l'utilisateur dépasse qlen
|
|||
|
|
*
|
|||
|
|
* - f, closure : tâche initiale
|
|||
|
|
*
|
|||
|
|
* Renvoie 1 quand elle a terminé, -1 en cas d'échec d'initialisation
|
|||
|
|
*/
|
|||
|
|
int sched_init(int nthreads, int qlen, taskfunc f, void *closure);
|
|||
|
|
|
|||
|
|
/* Enfile une nouvelle tâche (f, closure) à l'ordonanceur (s) */
|
|||
|
|
int sched_spawn(taskfunc f, void *closure, struct scheduler *s);
|