Asynchronous goodies built on libuv
$ clib install jwerle/uv-async
Starting async work can be done with the async(env, loop) macro function.
int
main (void) {
uv_loop_t *loop = uv_default_loop();
async(env, loop) {
queue(env, job);
wait(env, 500, called_500ms_later);
interval(env, 300, every_300ms);
}
return uv_run(loop, UV_RUN_DEFAULT);
}
You can queue a task with the queue(env, fn) macro function
async(env, loop) {
queue(env, job_fn);
}
You can set a task after a timeout with the wait(env, ms, fn) macro function.
async(env, loop) {
wait(env, 500, job_fn);
}
You can set an interval task with the interval(env, ms, fn) macro function.
async(env, loop) {
interval(env, 500, job_fn);
}
You can stop the inteval by setting the rc to 1 on the async_work_data_t *data pointer passed to the function.
static void
on_interval (async_work_data_t *work) {
if (++interval_count > 10) {
printf("interval limit reached. Stopping.. \n");
data->rc = 1;
} else {
printf("interval #%d\n", interval_count);
}
}
You can spawn a system command with the spawn(env, cmd, fn) macro. The fn will be called when the command has returned. The return code and signal code are attached to the async_work_data_t * pointer provided to the callback fn.
#include "async.h"
#include <assert.h>
#include <stdlib.h>
#include <stdio.h>
#include <sys/stat.h>
staic void
on_spawn (async_work_data_t *work) {
assert(0 == work->rc);
assert(0 == work->signal);
assert(work->process);
struct stat s;
assert(0 == stat("./foo", &s));
assert(0 == stat("./foo/bar", &s));
assert(0 == stat("./foo/bar/biz", &s));
}
int
main (void) {
async(env, uv_default_loop()) {
char *cmd[] = { "mkdir", "-p", "./foo/bar/biz" };
spawn(env, cmd, on_spawn);
}
return uv_run(uv_default_loop(), UV_RUN_DEFAULT);
}
MIT
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4