job_queue.h

Go to the documentation of this file.

#ifndef _JOB_QUEUE_H_
#define _JOB_QUEUE_H_

typedef void (*FuncPtr)(void *,void *);

/* job_queue node structure */
typedef struct node{
  FuncPtr fp;       /* pointer to function */
  void * args;      /* functioin arguements */
  struct node * next; 
} node;

/* queue_queue structure */
typedef struct{
  node * head;
  int size;
  pthread_mutex_t access;  
  pthread_cond_t empty; 
} List;

typedef struct{
  void * state;
  void * msg;
} JobArgs;


void * job_exec(void *job_q);


void job_submit(List *job_q,FuncPtr func,void* args,int args_size);



List * job_queue_init(int pool_size);

#endif

---