libs/rt-thread-official
libs
/
rt-thread-official
mirror of https://github.com/RT-Thread/rt-thread.git
4
0
Fork 0
Code Issues Releases Wiki Activity

给使用独立的defunct线程添加限制条件

This commit is contained in:
heyuanjie87 2024-08-30 16:30:55 +08:00 committed by Rbb666
parent 2351981e83
commit 1045bcb9df
3 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/rtthread.h
View File

@ -644,6 +644,7 @@ rt_ssize_t rt_mq_recv_prio(rt_mq_t mq,
void rt_thread_defunct_init(void); void rt_thread_defunct_init(void);
void rt_thread_defunct_enqueue(rt_thread_t thread); void rt_thread_defunct_enqueue(rt_thread_t thread);
rt_thread_t rt_thread_defunct_dequeue(void); rt_thread_t rt_thread_defunct_dequeue(void);
void rt_defunct_execute(void);
/* /*
* spinlock * spinlock

13
src/defunct.c
View File

@ -19,7 +19,9 @@ static rt_list_t _rt_thread_defunct = RT_LIST_OBJECT_INIT(_rt_thread_defunct);
static struct rt_spinlock _defunct_spinlock; static struct rt_spinlock _defunct_spinlock;
static struct rt_thread rt_system_thread; static struct rt_thread rt_system_thread;
rt_align(RT_ALIGN_SIZE) static rt_uint8_t rt_system_stack[SYSTEM_THREAD_STACK_SIZE]; rt_align(RT_ALIGN_SIZE) static rt_uint8_t rt_system_stack[SYSTEM_THREAD_STACK_SIZE];
#if defined(RT_USING_SMP) || defined(RT_USING_SMART)
static struct rt_semaphore system_sem; static struct rt_semaphore system_sem;
#endif
/** /**
* @brief Enqueue a thread to defunct queue. * @brief Enqueue a thread to defunct queue.
@ -34,8 +36,9 @@ void rt_thread_defunct_enqueue(rt_thread_t thread)
level = rt_spin_lock_irqsave(&_defunct_spinlock); level = rt_spin_lock_irqsave(&_defunct_spinlock);
rt_list_insert_after(&_rt_thread_defunct, &RT_THREAD_LIST_NODE(thread)); rt_list_insert_after(&_rt_thread_defunct, &RT_THREAD_LIST_NODE(thread));
rt_spin_unlock_irqrestore(&_defunct_spinlock, level); rt_spin_unlock_irqrestore(&_defunct_spinlock, level);
#if defined(RT_USING_SMP) || defined(RT_USING_SMART)
rt_sem_release(&system_sem); rt_sem_release(&system_sem);
#endif
} }
/** /**
@ -48,7 +51,7 @@ rt_thread_t rt_thread_defunct_dequeue(void)
rt_list_t *l = &_rt_thread_defunct; rt_list_t *l = &_rt_thread_defunct;
level = rt_spin_lock_irqsave(&_defunct_spinlock); level = rt_spin_lock_irqsave(&_defunct_spinlock);
if (l->next != l) if (!rt_list_isempty(l))
{ {
thread = RT_THREAD_LIST_NODE_ENTRY(l->next); thread = RT_THREAD_LIST_NODE_ENTRY(l->next);
rt_list_remove(&RT_THREAD_LIST_NODE(thread)); rt_list_remove(&RT_THREAD_LIST_NODE(thread));
@ -61,7 +64,7 @@ rt_thread_t rt_thread_defunct_dequeue(void)
/** /**
* @brief This function will perform system background job when system idle. * @brief This function will perform system background job when system idle.
*/ */
static void rt_defunct_execute(void) void rt_defunct_execute(void)
{ {
/* Loop until there is no dead thread. So one call to rt_defunct_execute /* Loop until there is no dead thread. So one call to rt_defunct_execute
* will do all the cleanups. */ * will do all the cleanups. */
@ -133,6 +136,7 @@ static void rt_defunct_execute(void)
} }
} }
#if defined(RT_USING_SMP) || defined(RT_USING_SMART)
static void rt_thread_system_entry(void *parameter) static void rt_thread_system_entry(void *parameter)
{ {
RT_UNUSED(parameter); RT_UNUSED(parameter);
@ -148,6 +152,7 @@ static void rt_thread_system_entry(void *parameter)
rt_defunct_execute(); rt_defunct_execute();
} }
} }
#endif
void rt_thread_defunct_init(void) void rt_thread_defunct_init(void)
{ {
@ -155,6 +160,7 @@ void rt_thread_defunct_init(void)
rt_spin_lock_init(&_defunct_spinlock); rt_spin_lock_init(&_defunct_spinlock);
#if defined(RT_USING_SMP) || defined(RT_USING_SMART)
rt_sem_init(&system_sem, "defunct", 0, RT_IPC_FLAG_FIFO); rt_sem_init(&system_sem, "defunct", 0, RT_IPC_FLAG_FIFO);
/* create defunct thread */ /* create defunct thread */
@ -168,4 +174,5 @@ void rt_thread_defunct_init(void)
32); 32);
/* startup */ /* startup */
rt_thread_startup(&rt_system_thread); rt_thread_startup(&rt_system_thread);
#endif
} }

4
src/idle.c
View File

@ -152,6 +152,10 @@ static void idle_thread_entry(void *parameter)
} }
#endif /* RT_USING_IDLE_HOOK */ #endif /* RT_USING_IDLE_HOOK */
#if !defined(RT_USING_SMP) && !defined(RT_USING_SMART)
rt_defunct_execute();
#endif
#ifdef RT_USING_PM #ifdef RT_USING_PM
void rt_system_power_manager(void); void rt_system_power_manager(void);
rt_system_power_manager(); rt_system_power_manager();