mirror of
https://github.com/averello/workdispatcher.git
synced 2026-03-03 18:24:16 +01:00
83dcebc227
Decide upon complitation time if you trust the compiler checks for NULL arguments passed to memory management functions.
63 lines
1.7 KiB
C
63 lines
1.7 KiB
C
//
|
|
// testQueue.c
|
|
// workdipatcher
|
|
//
|
|
// Created by George Boumis on 11/12/13.
|
|
// Copyright (c) 2013 George Boumis <developer.george.boumis@gmail.com>. All rights reserved.
|
|
//
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include "operationQueue.h"
|
|
#include <memory_management/memory_management.h>
|
|
|
|
#define ITER 10
|
|
|
|
void opf(WDOperation *operation, void *arg);
|
|
|
|
int main () {
|
|
char *const string = "Hello world";
|
|
WDOperationQueue *const operationQueue = WDOperationQueueAllocate();
|
|
WDOperationQueueSetName(operationQueue, "queue.name");
|
|
|
|
for (unsigned int i=0U; i<ITER; i++) {
|
|
WDOperation *const operation = WDOperationCreate(opf, string);
|
|
WDOperationQueueAddOperation(operationQueue, operation);
|
|
release(operation);
|
|
}
|
|
|
|
WDOperationQueueWaitAllOperations(operationQueue);
|
|
|
|
WDOperationQueueSuspend(operationQueue);
|
|
WDOperation *fistoperation = NULL;
|
|
char *string2 = "hohohohho";
|
|
for (unsigned int i=0U; i<ITER; i++) {
|
|
WDOperation *const operation = WDOperationCreate(opf, string2);
|
|
WDOperationQueueAddOperation(operationQueue, operation);
|
|
if (i==0U) { fistoperation = operation; }
|
|
release(operation);
|
|
}
|
|
WDOperationQueueResume(operationQueue);
|
|
WDOperationWaitUntilFinished(fistoperation);
|
|
release(operationQueue);
|
|
// memory_management_print_stats();
|
|
return 0;
|
|
}
|
|
|
|
void opf(WDOperation *operation, void *arg) {
|
|
static int i=0;
|
|
char *string = arg;
|
|
usleep(50000);
|
|
puts(string);
|
|
WDOperationQueue *const queue = WDOperationCurrentOperationQueue(operation);
|
|
puts(WDOperationQueueGetName(queue));
|
|
if (i++<ITER) {
|
|
WDOperation *const new = WDOperationCreate(opf, string);
|
|
WDOperationQueueAddOperation(queue, new);
|
|
release(new);
|
|
}
|
|
return;
|
|
}
|
|
|