1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
// SPDX-License-Identifier: GPL-2.0+
/*
* Copyright (C) 2017 Oracle. All Rights Reserved.
* Author: Darrick J. Wong <darrick.wong@oracle.com>
*/
#ifndef __LIBFROG_WORKQUEUE_H__
#define __LIBFROG_WORKQUEUE_H__
#include <pthread.h>
struct workqueue;
typedef void workqueue_func_t(struct workqueue *wq, uint32_t index, void *arg);
struct workqueue_item {
struct workqueue *queue;
struct workqueue_item *next;
workqueue_func_t *function;
void *arg;
uint32_t index;
};
struct workqueue {
void *wq_ctx;
pthread_t *threads;
struct workqueue_item *next_item;
struct workqueue_item *last_item;
pthread_mutex_t lock;
pthread_cond_t wakeup;
unsigned int item_count;
unsigned int thread_count;
unsigned int active_threads;
bool terminate;
bool terminated;
int max_queued;
pthread_cond_t queue_full;
};
int workqueue_create(struct workqueue *wq, void *wq_ctx,
unsigned int nr_workers);
int workqueue_create_bound(struct workqueue *wq, void *wq_ctx,
unsigned int nr_workers, unsigned int max_queue);
int workqueue_add(struct workqueue *wq, workqueue_func_t fn,
uint32_t index, void *arg);
int workqueue_terminate(struct workqueue *wq);
void workqueue_destroy(struct workqueue *wq);
#endif /* __LIBFROG_WORKQUEUE_H__ */
|
