code/queue_thread_model/worker.c

#include "worker.h"
#include <stdlib.h>

void execute(worker * w)
{

    w->fn_exec(w->argc, w->args, w->buf_return);
}

worker *new_worker(exec fn, int argc, char **args, int retc,
		   char *return_buf)
{
    worker *w = malloc(sizeof(worker));
    w->fn_exec = fn;
    w->argc = argc;
    w->args = args;
    w->buf_return = malloc(sizeof(char) * retc);


    return w;
}

void clear_worker(worker * w)
{
    free(w->buf_return);
    free(w);
}