1*10465441SEvalZero /*
2*10465441SEvalZero * Copyright (c) 2006-2018, RT-Thread Development Team
3*10465441SEvalZero *
4*10465441SEvalZero * SPDX-License-Identifier: Apache-2.0
5*10465441SEvalZero *
6*10465441SEvalZero * Change Logs:
7*10465441SEvalZero * Date Author Notes
8*10465441SEvalZero */
9*10465441SEvalZero #ifndef WORKQUEUE_H__
10*10465441SEvalZero #define WORKQUEUE_H__
11*10465441SEvalZero
12*10465441SEvalZero #include <rtthread.h>
13*10465441SEvalZero
14*10465441SEvalZero /* workqueue implementation */
15*10465441SEvalZero struct rt_workqueue
16*10465441SEvalZero {
17*10465441SEvalZero rt_list_t work_list;
18*10465441SEvalZero struct rt_work *work_current; /* current work */
19*10465441SEvalZero
20*10465441SEvalZero struct rt_semaphore sem;
21*10465441SEvalZero rt_thread_t work_thread;
22*10465441SEvalZero };
23*10465441SEvalZero
24*10465441SEvalZero struct rt_work
25*10465441SEvalZero {
26*10465441SEvalZero rt_list_t list;
27*10465441SEvalZero
28*10465441SEvalZero void (*work_func)(struct rt_work* work, void* work_data);
29*10465441SEvalZero void *work_data;
30*10465441SEvalZero };
31*10465441SEvalZero
32*10465441SEvalZero #ifdef RT_USING_HEAP
33*10465441SEvalZero /**
34*10465441SEvalZero * WorkQueue for DeviceDriver
35*10465441SEvalZero */
36*10465441SEvalZero struct rt_workqueue *rt_workqueue_create(const char* name, rt_uint16_t stack_size, rt_uint8_t priority);
37*10465441SEvalZero rt_err_t rt_workqueue_destroy(struct rt_workqueue* queue);
38*10465441SEvalZero rt_err_t rt_workqueue_dowork(struct rt_workqueue* queue, struct rt_work* work);
39*10465441SEvalZero rt_err_t rt_workqueue_cancel_work(struct rt_workqueue* queue, struct rt_work* work);
40*10465441SEvalZero rt_err_t rt_workqueue_cancel_work_sync(struct rt_workqueue* queue, struct rt_work* work);
41*10465441SEvalZero
rt_work_init(struct rt_work * work,void (* work_func)(struct rt_work * work,void * work_data),void * work_data)42*10465441SEvalZero rt_inline void rt_work_init(struct rt_work* work, void (*work_func)(struct rt_work* work, void* work_data),
43*10465441SEvalZero void* work_data)
44*10465441SEvalZero {
45*10465441SEvalZero rt_list_init(&(work->list));
46*10465441SEvalZero work->work_func = work_func;
47*10465441SEvalZero work->work_data = work_data;
48*10465441SEvalZero }
49*10465441SEvalZero #endif
50*10465441SEvalZero
51*10465441SEvalZero #endif
52*10465441SEvalZero
53