stm32多線程單片機(jī)如何實(shí)現(xiàn)多線程

STM 32系列是專門應(yīng)用在高性能、低成本、低功耗的嵌入式應(yīng)用設(shè)計(jì)的ARM Corte-M0，M0+，M3，M4和M7內(nèi)核，是主流的嵌入式單片機(jī)之一。

多線程通常是指從計(jì)算機(jī)軟件或硬件上實(shí)現(xiàn)多個(gè)線程并發(fā)執(zhí)行的技術(shù)，多線程技術(shù)有利于提升計(jì)算機(jī)整體處理性能。

基于STM32單片機(jī)的多線程源代碼實(shí)例1：

#include “Hal_Led/Hal_Led.h”

#include “Hal_delay/delay.h”

#include “Hal_Key/Hal_Key.h”

#include “ringbuffer.h”

#define APP_LED2_BLINK_EVENT 0x0001

#define HAL_LED1_BLINK_EVENT 0x0001

#define TASK_NO_TASK_RUNNING 0xFF

unsigned short Hal_ProcessEvent（ unsigned char task_id， unsigned short events ）;

unsigned short App_ProcessEvent（ unsigned char task_id， unsigned short events ）;

typedef unsigned short uint16;

typedef unsigned char uint8;

#define TASK_CNT 2 //定義線程的個(gè)數(shù)

//定義函數(shù)指針

typedef unsigned short （*pTaskEventHandlerFn）（ unsigned char task_id， unsigned short events ）;

//線程函數(shù)表

const pTaskEventHandlerFn tasksArr［］ =

{

Hal_ProcessEvent，

App_ProcessEvent

};

const unsigned char tasksCnt = sizeof（ tasksArr ） / sizeof（ tasksArr［ 0］ ）;

//uint16 *tasksEvents;

uint16 tasksEvents［TASK_CNT］ = { 0}; //每個(gè)線程有16位位域空間用于設(shè)置事件

static uint8 activeTaskID = 0xFF; //當(dāng)前任務(wù)ID，指示作用

#define SUCCESS 0x00

#define FAILURE 0x01

#define INVALID_TASK 0x02

uint8 osal_set_event（ uint8 task_id， uint16 event_flag ）

{

if （ task_id 《 tasksCnt ）

{

tasksEvents［task_id］ |= event_flag; // Stuff the event bit（s）

return （ SUCCESS ）;

}

else

{

return （ INVALID_TASK ）;

}

}

/**

* @brief 程序入口

* @param none

* @return none

*/

int main（ void）

{

unsigned short taskID = 0;

uint8 idx = 0;

SystemInit（）; //系統(tǒng)時(shí)鐘初始化

delayInit（ 72）; //滴答定時(shí)器初始化

Led_Init（）; //LED初始化

NVIC_PriorityGroupConfig（NVIC_PriorityGroup_2）;

osal_set_event（ 0， HAL_LED1_BLINK_EVENT）;

osal_set_event（ 1， APP_LED2_BLINK_EVENT）;

while（ 1）

{

do

{

if（tasksEvents［idx］） //輪訓(xùn)獲知哪個(gè)線程有事件需要進(jìn)行處理

{

break;

}

}

while （++idx 《 tasksCnt）;

if （idx 《 tasksCnt）

{

uint16 events;

events = tasksEvents［idx］;

tasksEvents［idx］ = 0; // 清除事件數(shù)組中的事件

activeTaskID = idx;

events = （tasksArr［idx］）（ idx， events ）; //調(diào)用線程函數(shù)

activeTaskID = TASK_NO_TASK_RUNNING;

tasksEvents［idx］ |= events; // 添加未處理的事件到本線程的事件組中

}

delayMs（ 1000）;

}

}

/**

* @brief 應(yīng)用層處理

* @param none

* @r

*/

unsigned short Hal_ProcessEvent（ unsigned char task_id， unsigned short events ）

{

if （ events & HAL_LED1_BLINK_EVENT ）

{

Led_Reverse（ 1）;

return events ^ HAL_LED1_BLINK_EVENT; //清除事件

}

}

/**

* @brief 硬件控制線程

* @param none

* @r

*/

unsigned short App_ProcessEvent（ unsigned char task_id， unsigned short events ）

{

if （ events & APP_LED2_BLINK_EVENT ）

{

Led_Reverse（ 2）;

return events ^ APP_LED2_BLINK_EVENT; //清除事件

}

基于STM32單片機(jī)的多線程源代碼實(shí)例2：

public class SimpleThread {

//私有的靜態(tài)成員內(nèi)部類，實(shí)現(xiàn)了Runnable接口

private static class ThreadMessage implements Runnable{

public void run（）{

String［］ info = {“消息1”，“消息2”， “消息3”， “消息4”};

try {

for（int i=0;i《info.length;i++）{

Thread.sleep（4000）;

displayThreadMessage（info［i］）;

}

} catch （InterruptedException e） {

displayThreadMessage（“不能正常工作”）;

}

}

}

//顯示消息，消息是當(dāng)前線程的名字

static void displayThreadMessage（String message）{

String threadName = Thread.currentThread（）.getName（）;

//格式化輸出線程消息

System.out.format（“%s： %s%n”， threadName， message）;

}

public static void main（String［］ args） throws InterruptedException {

// 中斷ThreadMessage線程之前延遲的毫秒數(shù)（默認(rèn)是一分鐘）

long delay =1000 * 60;

//如果有命令行參數(shù)，那么在命令行參數(shù)中給出推遲的時(shí)間

if（args.length》0）{

try {

delay =Long.parseLong（args［0］）*1000;

} catch （NumberFormatException e） {

System.err.println（“參數(shù)必須是整數(shù)”）;

System.exit（1）;

}

}

displayThreadMessage（“啟動(dòng)線程ThreadMessage.。?！保?

long startTime = System.currentTimeMillis（）;

Thread t = new Thread（new ThreadMessage（））;

t.start（）;

displayThreadMessage（“等待線程ThreadMessage結(jié)速。。。”）;

//循環(huán)直到ThreadMessage線程退出

while（t.isAlive（））{

displayThreadMessage（“繼續(xù)等待線程ThreadMessage.。?！保?

//最多等待3秒鐘ThreadMessage線程結(jié)速

t.join（3000）;

//如果線程t運(yùn)行的時(shí)間超過(guò)delay指定時(shí)間

if（（（System.currentTimeMillis（） - startTime） 》 delay） && t.isAlive（））{

displayThreadMessage（“線程ThreadMessage運(yùn)行時(shí)間太久了，不想等待！”）;

t.interrupt（）;

t.join（）;

}

}

displayThreadMessage（“結(jié)束線程ThreadMessage?。。　保?

}

}

基于STM32單片機(jī)的多線程源代碼實(shí)例3：

#include “Hal_Led/Hal_Led.h”

#include “Hal_delay/delay.h”

#include “Hal_Key/Hal_Key.h”

#include “ringbuffer.h”

#define APP_LED2_BLINK_EVENT 0x0001

#define HAL_LED1_BLINK_EVENT 0x0001

#define TASK_NO_TASK_RUNNING 0xFF

unsigned short Hal_ProcessEvent（ unsigned char task_id， unsigned short events ）;

unsigned short App_ProcessEvent（ unsigned char task_id， unsigned short events ）;

typedef unsigned short uint16;

typedef unsigned char uint8;

#define TASK_CNT 2 // 定義線程的個(gè)數(shù)

// 定義函數(shù)指針

typedef unsigned short （*pTaskEventHandlerFn）（ unsigned char task_id， unsigned short events ）;

// 線程函數(shù)表

const pTaskEventHandlerFn tasksArr［］ =

{

Hal_ProcessEvent，

App_ProcessEvent

};

const unsigned char tasksCnt = sizeof（ tasksArr ） / sizeof（ tasksArr［0］ ）;

//uint16 *tasksEvents;

uint16 tasksEvents［TASK_CNT］ = {0}; // 每個(gè)線程有 16 位位域空間用于設(shè)置事件

staTIc uint8 acTIveTaskID = 0xFF; // 當(dāng)前任務(wù) ID，指示作用

#define SUCCESS 0x00

#define FAILURE 0x01

#define INVALID_TASK 0x02

uint8 osal_set_event（ uint8 task_id， uint16 event_flag ）

{

if （ task_id 《 tasksCnt ）

{

tasksEvents［task_id］ |= event_flag; // Stuff the event bit（s）

return （ SUCCESS ）;

}

else

{

return （ INVALID_TASK ）;

}

}

/**

* @brief 程序入口

* @param none

* @return none

*/

int main（void）

{

unsigned short taskID = 0;

uint8 idx = 0;

SystemInit（）; // 系統(tǒng)時(shí)鐘初始化

delayInit（72）; // 滴答定時(shí)器初始化

Led_Init（）; //LED 初始化

NVIC_PriorityGroupConfig（NVIC_PriorityGroup_2）;

osal_set_event（0， HAL_LED1_BLINK_EVENT）;

osal_set_event（1， APP_LED2_BLINK_EVENT）;

while（1）

{

do

{

if（tasksEvents［idx］） // 輪訓(xùn)獲知哪個(gè)線程有事件需要進(jìn)行處理

{

break;

}

}

while （++idx 《 tasksCnt）;

if （idx 《 tasksCnt）

{

uint16 events;

events = tasksEvents［idx］;

tasksEvents［idx］ = 0; // 清除事件數(shù)組中的事件

acTIveTaskID = idx;

events = （tasksArr［idx］）（ idx， events ）; // 調(diào)用線程函數(shù)

activeTaskID = TASK_NO_TASK_RUNNING;

tasksEvents［idx］ |= events; // 添加未處理的事件到本線程的事件組中

}

delayMs（1000）;

}

}

/**

* @brief 應(yīng)用層處理

* @param none

* @r

*/

unsigned short Hal_ProcessEvent（ unsigned char task_id， unsigned short events ）

{

if （ events & HAL_LED1_BLINK_EVENT ）

{

Led_Reverse（1）;

return events ^ HAL_LED1_BLINK_EVENT; // 清除事件

}

}

/**

* @brief 硬件控制線程

* @param none

* @r

*/

unsigned short App_ProcessEvent（ unsigned char task_id， unsigned short events ）

{

if （ events & APP_LED2_BLINK_EVENT ）

{

Led_Reverse（2）;

return events ^ APP_LED2_BLINK_EVENT; // 清除事件

以上是關(guān)于STM32單片機(jī)的源代碼，希望對(duì)用戶有所幫助。

本文整合自百度百科、與非網(wǎng)、CSDN-辣條boy

責(zé)編AJX