Contents

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#include <uv.h>

#define FIB_UNTIL 25
uv_loop_t *loop;

long fib_(long t) {
    if (t == 0 || t == 1)
        return 1;
    else
        return fib_(t-1) + fib_(t-2);
}

void fib(uv_work_t *req) {
    int n = *(int *) req->data;
    if (random() % 2)
        sleep(1);
    else
        sleep(3);
    long fib = fib_(n);
    fprintf(stderr, "%dth fibonacci is %lu\n", n, fib);
}

void after_fib(uv_work_t *req, int status) {
    fprintf(stderr, "Done calculating %dth fibonacci\n", *(int *) req->data);
}

int main() {
    loop = uv_default_loop();

    int data[FIB_UNTIL];
    uv_work_t req[FIB_UNTIL];
    int i;
    for (i = 0; i < FIB_UNTIL; i++) {
        data[i] = i;
        req[i].data = (void *) &data[i];
        uv_queue_work(loop, &req[i], fib, after_fib);
    }

    return uv_run(loop, UV_RUN_DEFAULT);
}

Version data entries

15 entries across 15 versions & 2 rubygems

Version	Path
mt-libuv-4.1.04	ext/libuv/docs/code/queue-work/main.c
mt-libuv-4.1.03	ext/libuv/docs/code/queue-work/main.c
mt-libuv-4.1.02	ext/libuv/docs/code/queue-work/main.c
libuv-4.0.9	ext/libuv/docs/code/queue-work/main.c
libuv-4.0.2	ext/libuv/docs/code/queue-work/main.c
libuv-4.0.1	ext/libuv/docs/code/queue-work/main.c
libuv-4.0.0	ext/libuv/docs/code/queue-work/main.c
libuv-3.3.0	ext/libuv/docs/code/queue-work/main.c
libuv-3.2.4	ext/libuv/docs/code/queue-work/main.c
libuv-3.2.3	ext/libuv/docs/code/queue-work/main.c
libuv-3.2.2	ext/libuv/docs/code/queue-work/main.c
libuv-3.2.1	ext/libuv/docs/code/queue-work/main.c
libuv-3.2.0	ext/libuv/docs/code/queue-work/main.c
libuv-3.1.9	ext/libuv/docs/code/queue-work/main.c
libuv-3.1.8	ext/libuv/docs/code/queue-work/main.c