/
niceSOFT
/
libuv
Обзор
Документация
Войти
/
niceSOFT
/
libuv
Код
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
v1.x
docs/code/queue-cancel/main.c
59 строк
1 KB
Saúl Ibarra Corretgé
doc: add code samples from uvbook (unadapted)
28 апр 2017, 12:16
28 апр 2017, 12:16
d59d6e6
Код
Авторство
О чём код?
#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <uv.h> #define FIB_UNTIL 25 uv_loop_t *loop; uv_work_t fib_reqs[FIB_UNTIL]; 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) { if (status == UV_ECANCELED) fprintf(stderr, "Calculation of %d cancelled.\n", *(int *) req->data); } void signal_handler(uv_signal_t *req, int signum) { printf("Signal received!\n"); int i; for (i = 0; i < FIB_UNTIL; i++) { uv_cancel((uv_req_t*) &fib_reqs[i]); } uv_signal_stop(req); } int main() { loop = uv_default_loop(); int data[FIB_UNTIL]; int i; for (i = 0; i < FIB_UNTIL; i++) { data[i] = i; fib_reqs[i].data = (void *) &data[i]; uv_queue_work(loop, &fib_reqs[i], fib, after_fib); } uv_signal_t sig; uv_signal_init(loop, &sig); uv_signal_start(&sig, signal_handler, SIGINT); return uv_run(loop, UV_RUN_DEFAULT); }