Max 5 API Reference

parallel.h

#ifndef __PARALLEL_H__
#define __PARALLEL_H__

#if C74_PRAGMA_STRUCT_PACKPUSH
    #pragma pack(push, 2)
#elif C74_PRAGMA_STRUCT_PACK
    #pragma pack(2)
#endif

#ifdef __cplusplus
    extern "C" {
#endif // __cplusplus


#define PARALLEL_PRIORITY_DEFAULT   0x00
#define PARALLEL_PRIORITY_LOW       0x00
#define PARALLEL_PRIORITY_MEDIUM    0x04
#define PARALLEL_PRIORITY_HIGH      0x08

#define PARALLEL_MAX_WORKERS        8

#define PARALLEL_STATE_IDLE         0
#define PARALLEL_STATE_RUN          1
#define PARALLEL_STATE_DONE         2

typedef struct _parallel_task
{
    t_object    ob;
    void        *obex;
    void        *data;          // global task data
    method      workerproc;     // worker callback function 
    long        workercount;    // number of workers to use
    t_linklist  *workers;       // may wish to make a static array of some maximum size(32?)        
    char        priority;       // thread priority 
    char        benchmark;      // benchmark
    long        iteration;      // for benchmarking 
    double      begintime;      // for benchmarking
    double      endtime;        // for benchmarking
    long        cancel;         // for cancel request
    // some maintenance of threads/semaphores to use for execute?
} t_parallel_task;


typedef struct _parallel_worker
{
    t_object        ob;
    void            *obex;
    void            *data;          // worker specific data?
    method          workerproc;     // worker callback function, worker object passed in
    t_parallel_task *task;          // pointer to task parent (can be used to access global task data)
    long            id;             // worker id
    double          begintime;      // for benchmarking (uses task info)
    double          endtime;        // for benchmarking (uses task info)
// some maintenance of threads/semaphores to use for execute?
    
} t_parallel_worker;


void parallel_init(void);
long parallel_processorcount(void);
t_parallel_task *parallel_task_new(void *data, method workerproc, long workercount);
t_max_err parallel_task_execute(t_parallel_task *x);
t_max_err parallel_task_cancel(t_parallel_task *x);
void parallel_task_free(t_parallel_task *x);
void parallel_task_benchprint(t_parallel_task *x);
void parallel_task_data(t_parallel_task *x, void * data);
void parallel_task_workerproc(t_parallel_task *x, method workerproc);

t_parallel_worker *parallel_worker_new(void *data, method workerproc, t_parallel_task *task);
t_max_err parallel_worker_execute(t_parallel_worker *x);
void parallel_worker_free(t_parallel_worker *x);

#ifdef __cplusplus
}
#endif // __cplusplus

#if C74_PRAGMA_STRUCT_PACKPUSH
    #pragma pack(pop)
#elif C74_PRAGMA_STRUCT_PACK
    #pragma pack()
#endif

#endif // __PARALLEL_H__

Copyright © 2008, Cycling '74