RTT的stm32f4可以运行几个线程？

发布于 2020-08-26 08:18:29 浏览：2231 订阅该版

5 个回答

whj467467222 认证专家 2020-08-26

开源，分享，交流，共同进步

RT_Jerry 2020-08-26

这家伙很懒，什么也没写！

红枫 2020-08-26

这家伙很懒，什么也没写！

RT_Jerry 2020-08-26

这家伙很懒，什么也没写！

请登录后再发布评论，点击登录

追加回复

chenyingchun 2020-08-26

这家伙很懒，什么也没写！

李子成 2020-08-26

这家伙很懒，什么也没写！

RT_Jerry 2020-08-26

这家伙很懒，什么也没写！

李子成 2020-08-26

这家伙很懒，什么也没写！

RT_Jerry 2020-08-26

这家伙很懒，什么也没写！

/**************************************************************************************
										包含的头文件
***************************************************************************************/
#include "board.h"
#include "rtthread.h"

/**************************************************************************************
										自定义
***************************************************************************************/

/**************************************************************************************
										变量
***************************************************************************************/
static rt_thread_t 				led1_thread = RT_NULL;	/* 定义线程控制块 */
static rt_thread_t 				led2_thread = RT_NULL;
static rt_thread_t 				key_thread = RT_NULL;

static rt_thread_t 				receive_thread = RT_NULL;
static rt_thread_t 				send_thread = RT_NULL;

/*消息队列控制块*/
static rt_mq_t 					test_mq = RT_NULL;	/* 定义消息队列控制块 */
/**************************************************************************************
										函数声明
***************************************************************************************/
static void led1_thread_entry(void* parameter);
static void led2_thread_entry(void* parameter);
static void key_thread_entry(void* parameter);
static void receive_thread_entry(void* parameter);
static void send_thread_entry(void* parameter);
/**************************************************************************************
										main函数
***************************************************************************************/

int main(void)
{ 
	/* 
	 * 开发板硬件初始化，RTT系统初始化已经在main函数之前完成，
	 * 即在component.c文件中的rtthread_startup()函数中完成了。
	 * 所以在main函数中，只需要创建线程和启动线程即可。
	 */

rt_kprintf("这是一个STM32F407-RTT线程管理+消息队列实验！\n\n");
	rt_kprintf("按下K0挂起线程，按下K1恢复线程\n");
	rt_kprintf("按下K0或者K1发送队列消息\n");
	rt_kprintf("receive任务接收到消息在串口回显\n");
	
	
	
   /* 创建一个消息队列 */
	test_mq = rt_mq_create("test_mq",/* 消息队列名字 */
									4,			/* 消息的最大长度 */
									20,		/* 消息队列的最大容量 */
									RT_IPC_FLAG_FIFO);/* 队列模式 FIFO(0x00)*/
	if (test_mq != RT_NULL)
		rt_kprintf("消息队列创建成功！\n\n");

led1_thread =                          /* 线程控制块指针 */
		rt_thread_create( "led1",              /* 线程名字 */
                      led1_thread_entry,   /* 线程入口函数 */
                      RT_NULL,             /* 线程入口函数参数 */
                      512,                 /* 线程栈大小 */
                      6,                   /* 线程的优先级 */
                      20);                 /* 线程时间片 */
	if (led1_thread != RT_NULL)    /* 启动线程，开启调度 */
		rt_thread_startup(led1_thread);
	else
		return -1;

led2_thread =                          /* 线程控制块指针 */
		rt_thread_create( "led2",              /* 线程名字 */
                      led2_thread_entry,   /* 线程入口函数 */
                      RT_NULL,             /* 线程入口函数参数 */
                      512,                 /* 线程栈大小 */
                      3,                   /* 线程的优先级 */
                      20);                 /* 线程时间片 */
	if (led2_thread != RT_NULL)    /* 启动线程，开启调度 */
		rt_thread_startup(led2_thread);
	else
		return -1;

key_thread =                          /* 线程控制块指针 */
		rt_thread_create( "key",              /* 线程名字 */
                      key_thread_entry,   /* 线程入口函数 */
                      RT_NULL,             /* 线程入口函数参数 */
                      512,                 /* 线程栈大小 */
                      2,                   /* 线程的优先级 */
                      20);                 /* 线程时间片 */
	if (key_thread != RT_NULL)    /* 启动线程，开启调度 */
		rt_thread_startup(key_thread);
	else
		return -1;
	 
	
	receive_thread =                          /* 线程控制块指针 */
		rt_thread_create( "receive",              /* 线程名字 */
                      receive_thread_entry,   /* 线程入口函数 */
                      RT_NULL,             /* 线程入口函数参数 */
                      512,                 /* 线程栈大小 */
                      5,                   /* 线程的优先级 */
                      20);                 /* 线程时间片 */
                   
    /* 启动线程，开启调度 */
	if (receive_thread != RT_NULL)
		rt_thread_startup(receive_thread);
	else
		return -1;
    
	send_thread =                          /* 线程控制块指针 */
		rt_thread_create( "send",              /* 线程名字 */
                      send_thread_entry,   /* 线程入口函数 */
                      RT_NULL,             /* 线程入口函数参数 */
                      1024,                 /* 线程栈大小 */
                      4,                   /* 线程的优先级 */
                      20);                 /* 线程时间片 */
                   
    /* 启动线程，开启调度 */
	if (send_thread != RT_NULL)
		rt_thread_startup(send_thread);
	else
		return -1;

}

/**************************************************************************************
										线程定义
***************************************************************************************/
static void led1_thread_entry(void* parameter)
{
	while (1)
	{
		LED1=0;
		Key_Delay(0xfffff*5);	//0xfffff*17，大概1s左右
//		rt_kprintf("led1_thread running,LED1_ON\r\n");
		LED1=1;	
		Key_Delay(0xfffff*5);	//0xfffff*17，大概1s左右
//		rt_kprintf("led1_thread running,LED1_OFF\r\n");
		rt_thread_delay(300);   /* 延时300个tick */	
	}
}
static void led2_thread_entry(void* parameter)
{	
	rt_err_t uwRet = RT_EOK;	
	uint32_t r_queue;
	while (1)
	{
		LED2=0;
		rt_thread_delay(300);   /* 延时300个tick */
		rt_kprintf("led2_thread running,LED2_ON\r\n");
		LED2=1;
		rt_thread_delay(300);   /* 延时300个tick */		 		
		rt_kprintf("led2_thread running,LED2_OFF\r\n");

}
}
static void key_thread_entry(void* parameter)
{	
	rt_err_t		uwRet = RT_EOK;
	u8 key;           //保存键值
	
	while (1)
	{
		key=KEY_Scan(0);		//得到键值
		if(key==KEY0_PRES)
		{
			rt_kprintf("挂起LED1线程！\n");
			uwRet = rt_thread_suspend(led1_thread);//挂起LED1线程
			rt_schedule();
			if(RT_EOK == uwRet)
			{
				rt_kprintf("挂起LED1线程成功！\n");
			}
			else
			{
				rt_kprintf("挂起LED1线程失败！失败代码：0x%lx\n",uwRet);
			}
		}
		if(key==KEY1_PRES)
		{
			rt_kprintf("恢复LED1线程！\n");
			uwRet = rt_thread_resume(led1_thread);//恢复LED1线程
			if(RT_EOK == uwRet)
			{
				rt_kprintf("恢复LED1线程成功！\n");
			}
			else
			{
				rt_kprintf("恢复LED1线程失败！失败代码：0x%lx\n",uwRet);
			}
		}
		rt_thread_delay(200);
	}
}

static void receive_thread_entry(void* parameter)
{	
	rt_err_t uwRet = RT_EOK;	
	uint32_t r_queue;
	/* 任务都是一个无限循环，不能返回 */
	while (1)
	{
		rt_kprintf("receive_thread running\r\n");
		/* 队列读取（接收），等待时间为一直等待 */
		uwRet = rt_mq_recv(test_mq,				/* 读取（接收）队列的ID(句柄) */
								&r_queue,				/* 读取（接收）的数据保存位置 */
								sizeof(r_queue),		/* 读取（接收）的数据的长度 */
								RT_WAITING_FOREVER); /* 等待时间：一直等 */
		if(RT_EOK == uwRet)
		{
			rt_kprintf("本次接收到的数据是：%d\n",r_queue);
		}
		else
		{
			rt_kprintf("数据接收出错,错误代码: 0x%lx\n",uwRet);
		}
		rt_thread_delay(200);
	}
}

static void send_thread_entry(void* parameter)
{	
	rt_err_t		uwRet = RT_EOK;	
	uint32_t 	send_data1 = 1;
	uint32_t 	send_data2 = 2;
	u8 			key_send;           //保存键值
	while (1)
	{
		rt_kprintf("send_thread running\r\n");
		key_send=KEY_Scan(0);		//得到键值
		if( key_send==KEY0_PRES )/* k0 被按下 */
		{
			/* 将数据写入（发送）到队列中，等待时间为 0  */
			uwRet = rt_mq_send(	test_mq,					/* 写入（发送）队列的ID(句柄) */
										&send_data1,			/* 写入（发送）的数据 */
										sizeof(send_data1));	/* 数据的长度 */
			if(RT_EOK != uwRet)
			{
				rt_kprintf("数据不能发送到消息队列！错误代码: %lx\n",uwRet);
			}
		}
		if( key_send==KEY1_PRES )/* K1 被按下 */
		{
		/* 将数据写入（发送）到队列中，等待时间为 0  */
		uwRet = rt_mq_send(	test_mq,					/* 写入（发送）队列的ID(句柄) */
									&send_data2,			/* 写入（发送）的数据 */
									sizeof(send_data2));	/* 数据的长度 */
			if(RT_EOK != uwRet)
			{
				rt_kprintf("数据不能发送到消息队列！错误代码: %lx\n",uwRet);
			}
		}
		rt_thread_delay(20);
	}
}

/********************************END OF FILE****************************/