嵌入式SoC多线程架构迁移多进程架构开发技巧

电子设计联盟 · 发表于 2024-12-17 08:00:00

vx325zcswqz64087017.gif

点击上方蓝色字体，关注我们
将嵌入式SoC开发从单进程多线程架构迁移多进程架构是一项需要谨慎规划和实施的任务，尤其在资源有限的嵌入式系统中。

jrawntfyaji64087118.png

这种架构转变通常是为了提高系统的稳定性、隔离性、安全性和并发处理能力。

在单进程多线程架构中，多个线程共享相同的内存空间、文件描述符和全局变量，适合处理轻量级任务并发。

然而，这种架构的缺点在于：

共享资源管理复杂：线程之间共享内存，容易引发数据竞争和资源冲突问题，特别是在锁机制使用不当时。

崩溃影响较大：如果其中一个线程发生崩溃，整个进程都会受影响，导致系统不稳定。

调试困难：由于线程共享状态，调试内存问题和线程同步问题较为复杂。

多进程架构将应用分割成多个独立的进程，每个进程有自己独立的内存空间和资源控制。

这种架构带来的好处包括：

稳定性增强：一个进程崩溃不会影响其他进程，系统更具弹性。

资源隔离：不同进程之间互相独立，降低数据竞争问题。

安全性提升：不同的进程可以运行在不同的权限下，增强系统安全性。

1
架构迁移步骤
1、分析系统功能模块
首先，需要对现有的单进程多线程架构中的功能模块进行分析。

找出哪些模块可以独立运行，并识别哪些模块间存在紧密通信的依赖。

这些依赖关系在多进程架构中将通过进程间通信（IPC）来处理。

2、确定进程划分
根据功能模块的划分，将系统设计为多个独立的进程。

例如：

数据采集进程：专门处理传感器数据采集。

数据处理进程：执行数据的分析与处理。

通信进程：负责与外部设备或服务器的通信。

用户界面进程：与用户进行交互。

3、实现进程间通信（IPC）
在多进程架构中，线程共享的内存变为各自独立，因此需要通过进程间通信机制来传递信息。

常用的IPC机制包括：

消息队列：适合传递短小消息的场景，带有优先级机制。

共享内存：用于高效的大数据量传输，但需额外的同步控制。

信号量：用于同步进程间的操作，确保操作有序进行。

管道（pipe）：单向通信通道，适合父子进程间的数据传输。

Socket：用于不同设备或跨网络通信。

4、进程的创建与管理
在多进程架构中，使用fork()系统调用或其他多进程框架来创建多个进程。
! C$ E8 h) D# {7 Y7 B2 k1 b' u( K

可以通过守护进程来管理子进程的启动、停止和监控。

5、异常处理与监控
使用wait()和waitpid()系统调用来监控子进程的状态，确保进程能够正确退出或重启。

1 m3 L$ `0 v% Q! v; v# g r) Z
可以通过设计一个监控进程，定期检查各个子进程的健康状态。

6、资源分配与优化
在多进程架构中，由于每个进程都有自己的内存空间，需要更加精确地控制资源的分配和使用。

可以通过内存共享池来优化不同进程的内存占用，并确保嵌入式系统的性能。
2
架构迁移的关键点
性能与资源管理
多进程架构在嵌入式系统中的使用可能会增加内存和资源开销，因为每个进程都有自己的独立地址空间和资源。

为了优化性能，可以考虑使用轻量级的IPC机制，或者根据需求调整进程的数量和功能分布。
4 B) N6 s& e3 n" I# j& e: F

进程通信的选择
除了共享内存，进程间通信还可以使用消息队列、管道或socket，根据实际需要选择最合适的方式。

共享内存虽然在大数据传输时效率高，但需要进行同步处理（如使用信号量）来避免并发访问冲突。
- e3 E* B6 @% A8 M$ Y1 H

稳定性和隔离性
多进程架构极大提高了系统的隔离性。

如果某个进程崩溃，其他进程仍然能够继续正常工作，增强了系统的稳定性。

通过父进程监控子进程的状态，可以实现崩溃时自动重启功能，进一步提升系统的容错性。
3
迁移实例
这里以一个简单的嵌入式系统为例，逐步展示如何从单进程多线程架构转变为多进程架构。

在这个架构中，系统有三个主要功能模块：

温度传感器数据采集线程。

数据处理线程。

通信模块线程，将处理后的数据发送到远程服务器。

这些线程共享同一个内存空间，通过共享的全局变量来交换数据。

原始多线程代码如下：

// 全局共享变量float temperature_data = 0.0;
// 模拟读取温度传感器数据float read_temperature_sensor() { return 25.0 + (rand() % 10); // 随机模拟温度}
// 模拟处理数据void process_temperature_data(float temp) { printf("Processing temperature data: %.2f
", temp); sleep(1); // 模拟数据处理时间}
// 模拟发送数据到服务器void send_data_over_network(float temp) { printf("Sending data over network: %.2f
", temp); sleep(1); // 模拟网络通信时间}
// 温度采集线程void* temperature_thread(void* arg) { while (1) {       temperature_data = read_temperature_sensor();       printf("Temperature read: %.2f
", temperature_data);       sleep(2); // 模拟采集周期 } return NULL;}
// 数据处理线程void* processing_thread(void* arg) { while (1) {       process_temperature_data(temperature_data); } return NULL;}
// 通信线程void* communication_thread(void* arg) { while (1) {       send_data_over_network(temperature_data); } return NULL;}
int main() { pthread_t temp_thread, proc_thread, comm_thread;
// 创建三个线程 pthread_create(&temp_thread, NULL, temperature_thread, NULL); pthread_create(&proc_thread, NULL, processing_thread, NULL); pthread_create(&comm_thread, NULL, communication_thread, NULL);
// 等待线程完成 pthread_join(temp_thread, NULL); pthread_join(proc_thread, NULL); pthread_join(comm_thread, NULL);
return 0;}

存在问题：

数据竞争：多个线程访问和修改同一个全局变量temperature_data，容易出现数据竞争。

稳定性：如果某个线程崩溃，整个进程都会终止。

调试困难：由于线程共享资源，调试内存问题比较复杂。

多进程架构优化思路：

/ @4 s7 n2 b: D- y2 p: |6 g
共享内存创建

使用 ftok() 生成一个唯一的键值来标识共享内存。

shmget() 创建一个共享内存段，指定共享内存大小为 sizeof(float)，用于存储温度数据。

shmat() 将共享内存映射到进程的地址空间，使每个子进程都可以访问这块共享内存。

! I- \! _; E" h+ T C
子进程的创建
使用 fork() 创建三个子进程，分别负责温度数据采集、数据处理和数据发送。

每个子进程拥有自己的独立内存空间，但通过共享内存来交换数据。

/ f- L! P+ Y- n. p4 T4 Q9 S; Q# f! o
数据传递
温度采集进程：负责读取传感器数据，并将数据写入共享内存中的 temperature_data。

数据处理进程：从共享内存读取温度数据，并进行相应的处理操作。

通信进程：从共享内存读取处理后的数据，并将其通过网络发送到远程服务器。
3 Y* |5 j8 H* y" w4 {4 I+ l" ~

进程管理
父进程使用 wait() 函数来等待子进程的执行结束，确保所有子进程正确地运行。

在系统终止时，父进程会分离并删除共享内存，防止内存泄漏。

优化后的多进程架构代码：

// 模拟读取温度传感器数据float read_temperature_sensor() { return 25.0 + (rand() % 10); // 随机模拟温度}
// 模拟处理数据void process_temperature_data(float temp) { printf("Processing temperature data: %.2f
", temp); sleep(1); // 模拟数据处理时间}
// 模拟发送数据到服务器void send_data_over_network(float temp) { printf("Sending data over network: %.2f
", temp); sleep(1); // 模拟网络通信时间}
int main() { // 创建共享内存段 key_t key = ftok("shmfile", 65); // 生成共享内存键值 int shmid = shmget(key, sizeof(float), 0666 | IPC_CREAT); // 创建共享内存 float *temperature_data = (float *) shmat(shmid, NULL, 0); // 将共享内存映射到进程地址空间
// 父进程创建子进程 pid_t pid = fork();
if (pid == 0) {       // 子进程1：负责温度采集       while (1) {          *temperature_data = read_temperature_sensor();          printf("Temperature read: %.2f
", *temperature_data);          sleep(2); // 模拟采集周期       } } else {       pid_t pid2 = fork();       if (pid2 == 0) {          // 子进程2：负责数据处理          while (1) {             process_temperature_data(*temperature_data);          }       } else {          pid_t pid3 = fork();          if (pid3 == 0) {             // 子进程3：负责数据发送             while (1) {                   send_data_over_network(*temperature_data);             }          } else {             // 父进程：等待所有子进程             wait(NULL); // 等待第一个子进程结束             wait(NULL); // 等待第二个子进程结束             wait(NULL); // 等待第三个子进程结束
            // 分离和删除共享内存             shmdt(temperature_data);             shmctl(shmid, IPC_RMID, NULL);          }       } }
return 0;}

从单进程多线程架构转向多进程架构，可以显著提高嵌入式系统的稳定性、隔离性和安全性。

通过共享内存、消息队列等进程间通信机制，能够有效地实现进程之间的数据交换。

虽然多进程架构会带来一定的资源开销，但在处理复杂应用时，其优势非常明显，特别是对于需要高并发、容错性和模块化设计的系统。

ruk0fkh2qqe64087218.jpg

gueo2sl1uxl64087318.gif

点击阅读原文，更精彩~