#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include "wqueue.h"


wqueue_t *wq;

void print_me(void *data) {
	printf(":: %s\n", (char*)data);
}

void sum(void *data) {
	int *a = (int*)data;
	char *buffer = malloc(10*sizeof(char));
	sprintf(buffer, "%i", a[0]+a[1]);
	printf("Inserting subjobs...\n");
	wqueue_ts_insert(wq, -1, &print_me, buffer);
	wqueue_ts_insert(wq, -1, &free, buffer);
}

int main() {
	wq = malloc(sizeof(wqueue_t));
	if(wq==NULL)
		return 1;
	wq->first = NULL;
	wq->last = NULL;
	pthread_mutex_init(&wq->condition_mutex, NULL);
	int p[2] = {5, 10};
	int q[2] = {50, 100};
	wqueue_ts_insert(wq, 3, (work_f)print_me, "Thread A. 3");
	wqueue_ts_insert(wq, 2, (work_f)print_me, "Thread B. 2");
	wqueue_ts_insert(wq, 3, (work_f)print_me, "Thread C. 3");
	wqueue_ts_insert(wq, 4, (work_f)print_me, "Thread D. 4");
	wqueue_ts_insert(wq, 3, (work_f)print_me, "Thread E. 3");
	wqueue_ts_insert(wq, 2, (work_f)print_me, "Thread F. 2");
	wqueue_ts_insert(wq, 1, (work_f)print_me, "Thread G. 1");
	wqueue_ts_insert(wq, 3, (work_f)print_me, "Thread H. 3");
	wqueue_ts_insert(wq, 1, (work_f)sum, q);
	wqueue_ts_insert(wq, 4, (work_f)sum, p);
	wqueue_thread_pool(wq, 3);
	return 0;
}