74 lines
2.4 KiB
C
74 lines
2.4 KiB
C
/*
|
|
* Priority Queue
|
|
*
|
|
* COPYRIGHT (C) 2013-2015, Shanghai Real-Thread Technology Co., Ltd
|
|
* http://www.rt-thread.com
|
|
*
|
|
* This file is part of RT-Thread (http://www.rt-thread.org)
|
|
*
|
|
* All rights reserved.
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along
|
|
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
*
|
|
* Change Logs:
|
|
* Date Author Notes
|
|
* 2013-11-04 Grissiom add comment
|
|
*/
|
|
|
|
#ifndef __PRIO_QUEUE_H__
|
|
#define __PRIO_QUEUE_H__
|
|
|
|
#include <rtthread.h>
|
|
|
|
#define RT_PRIO_QUEUE_PRIO_MAX 32
|
|
|
|
struct rt_prio_queue_item;
|
|
|
|
struct rt_prio_queue {
|
|
rt_uint32_t bitmap;
|
|
struct rt_prio_queue_item *head[RT_PRIO_QUEUE_PRIO_MAX];
|
|
struct rt_prio_queue_item *tail[RT_PRIO_QUEUE_PRIO_MAX];
|
|
/* push thread suspend on the mempool, not queue */
|
|
rt_list_t suspended_pop_list;
|
|
rt_size_t item_sz;
|
|
|
|
struct rt_mempool pool;
|
|
};
|
|
|
|
rt_err_t rt_prio_queue_init(struct rt_prio_queue *que,
|
|
const char *name,
|
|
void *buf,
|
|
rt_size_t bufsz,
|
|
rt_size_t itemsz);
|
|
void rt_prio_queue_detach(struct rt_prio_queue *que);
|
|
|
|
rt_err_t rt_prio_queue_push(struct rt_prio_queue *que,
|
|
rt_uint8_t prio,
|
|
void *data,
|
|
rt_int32_t timeout);
|
|
rt_err_t rt_prio_queue_pop(struct rt_prio_queue *que,
|
|
void *data,
|
|
rt_int32_t timeout);
|
|
#ifdef RT_USING_HEAP
|
|
struct rt_prio_queue* rt_prio_queue_create(const char *name,
|
|
rt_size_t item_nr,
|
|
rt_size_t item_sz);
|
|
void rt_prio_queue_delete(struct rt_prio_queue *que);
|
|
#endif
|
|
|
|
void rt_prio_queue_dump(struct rt_prio_queue *que);
|
|
|
|
#endif /* end of include guard: __PRIO_QUEUE_H__ */
|