Question about ext_sysparallel.h

Hello Toshiro,

We probably won't be completely documenting this anytime soon, but here is a simplified example of the portions of creating, executing, and freeing a t_sysparallel_task. This is reduced from poly~, alternating patcher voices in the threads.

If you can describe what you want to accomplish, or have some attempt at using this code with specific questions, I would be happy to try and answer them.

-Joshua

typedef struct _myobj_parallel
{
    t_myobj    *myobj;
    long    count;
} t_myobj_parallel;

void myobj_workerproc(t_sysparallel_worker *w)
{
    t_myobj *x = ((t_myobj_parallel *)(w->data))->myobj;
    long count = ((t_myobj_parallel *)(w->data))->count;
    long i,threadcount;

    threadcount = w->task->workercount;

    // alternate every threadcount voices between threads
    for (i = w->id; i < count; i+=threadcount) {
        if (x->p_patchers[i].r_mute)
            continue;
        if (x->p_patchers[i].r_chain) {
            // compute dsp chain
        }
    }
}

void myobj_run(t_myobj *x, long count)
{
    t_max_err err;
    long i;
    t_myobj_parallel p;

    // setup our workerproc data pointer
    p.myobj = x;
    p.count = count;

    if (!x->p_paralleltask)
        x->p_paralleltask = sysparallel_task_new(&p,(method)myobj_workerproc,x->p_threadcount);

    // set task priority to audio
    x->p_paralleltask->priority = SYSPARALLEL_PRIORITY_HIGH;

    sysparallel_task_data(x->p_paralleltask,&p);

    // execute task. if there is an error it means we're trying to run parallel in nested instances
    if (err=sysparallel_task_execute(x->p_paralleltask)) {
        if (!x->p_parallelerror) {
            object_error((t_object *)x,"use of nested, parallel enabled objects is not supported. disabling for inner myobj~ object(s)");
            x->p_parallelerror = TRUE;
        }
        // do your fallback here
    }
}

void myobj_free(t_myobj *x)
{
    dsp_free((t_pxobject *)x);

    if (x->p_paralleltask)
            sysparallel_task_free(x->p_paralleltask);

}