RT-Thread-第13天：生产者-消费者问题 [15天rt-thread入门学习]RT-Thread问答社区

第13天：生产者-消费者问题 [15天rt-thread入门学习]

发布于 2018-06-04 21:39:13 浏览：1861 订阅该版

* 本帖最后由 wolfgang2018 于 2018-6-4 22:17 编辑 *

1、创建两个任务，任务1运行中向任务2发送一个信号，任务2收到信号后退出任务的执行

运行结果：
![01.jpg](/uploads/201806/04/213601w7qz0aa9zavkq91e.jpg)
在Thread2  count 在运行5之前，接收到关闭线程信号，Thread2 之后就停止运行；
Thread2 在独立运行10次后，也停止运行了。

相关代码：
```
//定义两个用户线程、以及退出运行控制标记
static rt_thread_t utid1 = RT_NULL, utid2 = RT_NULL;
static rt_uint8_t rt_break1=0, rt_break2=0;  //默认推出控制置0；

/* 用户线程2的信号处理函数 */
void thread2_user_signal_handler(int sig){
	rt_kprintf("thread2 received signal close %d ", sig);
	rt_break2=1; //收到信号退出位置1；
}

/* 用户线程1的入口函数 */
static void user_thread1_entry(void *parameter) {
 rt_uint8_t cnt = 0;
 /* 运行10次 */
 while (1){
 //线程1运行10次后，向线程2发送一个停止线程的信号, 
 //在线程1发送停止信号后10次运行后，线程1也停止线程；
 if (((cnt/10)>=1) & ((cnt % 10)==0)){
 if (rt_break1==1){
 break;
 }
 rt_thread_kill(utid2, SIGUSR1);
 rt_break1=1;
 }
 rt_kprintf("thread1 count : %d ", cnt);
 cnt++;
 rt_thread_delay(100);
 }
 rt_kprintf("thread1 close now!!!!! ");
}

/* 用户线程2的入口函数 */
static void user_thread2_entry(void *parameter) {
 rt_uint8_t cnt = 0;
 /* 安装信号 */
 rt_signal_install(SIGUSR1, thread2_user_signal_handler);
 rt_signal_unmask(SIGUSR1);	
 /* 运行10次 */
 while (1) {
 if (rt_break2==1) {
 break;
 }
 rt_kprintf("thread2 count : %d ", cnt);
 cnt++;
 rt_thread_delay(200);
 }
 rt_kprintf("thread2 close now!!! ");
}

/* 用户线程控制作业函数 */
int user_signal_sample_init(){
  utid1 = rt_thread_create("ut1", user_thread1_entry, RT_NULL,
	                         THREAD_STACK_SIZE, THREAD_PRIORITY-1, THREAD_TIMESLICE);
  if (utid1 != RT_NULL) {
      rt_thread_startup(utid1);
  }
  utid2 = rt_thread_create("ut2", user_thread2_entry, RT_NULL,
                                 THREAD_STACK_SIZE, THREAD_PRIORITY+1, THREAD_TIMESLICE);
  if (utid2 != RT_NULL) {
    rt_thread_startup(utid2);
  }
  return 0;
}

//修改命令行定义方式
/* 如果设置了RT_SAMPLES_AUTORUN，则加入到初始化线程中自动运行 */
#if defined (RT_SAMPLES_AUTORUN) && defined(RT_USING_COMPONENTS_INIT)
    INIT_APP_EXPORT(signal_sample_init);
    INIT_APP_EXPORT(user_signal_sample_init);
#endif
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(signal_sample_init, signal sample);
MSH_CMD_EXPORT(user_signal_sample_init, signal sample);

```

[https://www.rt-thread.org/qa/thread-7210-1-1.html](第01天：初识RT-Thread [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7211-1-1.html](第02天：系统启动代码和用户入口 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7261-1-1.html](第03天：线程的创建与删除 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7262-1-1.html](第04天：空闲任务及其钩子函数 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7263-1-1.html](第05天：中断和临界区保护 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7264-1-1.html](第06天：堆的初始化和使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7265-1-1.html](第07天：信号量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7266-1-1.html](第08天：互斥量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7267-1-1.html](第09天：邮箱的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7268-1-1.html](第10天：消息队列的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7271-1-1.html](第11天：事件的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7272-1-1.html](第12天：生产者-消费者问题 [15天rt-thread入门学习])

[https://www.rt-thread.org/qa/thread-7274-1-1.html](第14天：软件定时器 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7275-1-1.html](第15天：内存池[15天rt-thread入门学习])