打印
[ARM入门]

C-Thread-Pool线程池

[复制链接]
22|0
手机看帖
扫描二维码
随时随地手机跟帖
跳转到指定楼层
楼主
C-Thread-Pool是一个轻量级、易用的线程池实现。

https://github.com/Pithikos/C-Thread-PoolMIT 

license


特点:

  • 符合ANSI C 和 POSIX 标准

  • 支持暂停/恢复/等待操作

  • 简单易懂的 API

  • 经过充分测试


C-Thread-Pool库未预编译,我们需要与项目一起编译。在 Linux 上用 gcc 编译时,需要添加标志 -pthread,如:

gcc example.c thpool.c -D THPOOL_DEBUG -pthread -o example

基本用法:

1、在源文件中包含头文件:#include "thpool.h"

2、创建一个具有所需线程数的线程池:threadpool thpool = thpool_init(4);

3、向池中添加工作:thpool_add_work(thpool, (void*)function_p, (void*)arg_p);

C-Thread-Pool应用API可查看thpool.h 文件:

C-Thread-Pool并发处理数据的例子:

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include "thpool.h"

typedef struct
{
    int *data;
    int index;
    long result;
} test_data_t;

void task(void *arg)
{
    test_data_t *test_data = (test_data_t *)arg;
    test_data->result = (long)test_data->data[test_data->index] * test_data->data[test_data->index];
    printf("Thread #%u work, test_data->result = %ld\n", (int)pthread_self(), test_data->result);
    free(test_data);
}

int main(int argc, char *argv[])
{
    int data[] = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
    int num_elements = sizeof(data) / sizeof(data[0]);

    // 创建一个线程池,包含4个线程
    threadpool thpool = thpool_init(4);

    // 添加num_elements个任务到线程池
    for (int i = 0; i < num_elements; i++)
    {
        test_data_t *test_data = malloc(sizeof(test_data_t));
        test_data->data = data;
        test_data->index = i;
        thpool_add_work(thpool, task, test_data);
    }

thpool_wait(thpool);
puts("Killing threadpool");
thpool_destroy(thpool);

    return 0;
}
THPOOL_DEBUG: Created thread 0 in pool 
THPOOL_DEBUG: Created thread 1 in pool
THPOOL_DEBUG: Created thread 2 in pool
THPOOL_DEBUG: Created thread 3 in pool
Thread #3894134336 work, test_data->result = 1
Thread #3910919744 work, test_data->result = 9
Thread #3902527040 work, test_data->result = 16
Thread #3885741632 work, test_data->result = 4
Thread #3910919744 work, test_data->result = 25
Thread #3910919744 work, test_data->result = 64
Thread #3910919744 work, test_data->result = 100
Thread #3885741632 work, test_data->result = 81
Thread #3902527040 work, test_data->result = 36
Thread #3894134336 work, test_data->result = 49
Killing threadpool

在嵌入式系统中,线程池技术可以应用于多种场景,如数据处理、网络通信、传感器数据采集等。

网络服务器
  • 用途:在网络服务器中,使用线程池处理多个客户端的请求。每个客户端的请求可以被视为一个任务,线程池中的线程可以并发地处理这些任务。
  • 优势:使用线程池可以提高服务器的并发处理能力,减少因频繁创建和销毁线程而带来的开销,从而提高服务器的响应速度和整体性能。
数据处理
  • 用途:在数据处理场景中,使用线程池用于并行处理大量数据。例如,对大量数据进行排序、搜索或分析时,可以将数据分成多个小块,每个小块作为一个任务交给线程池处理。
  • 优势:通过并行处理,可以显著缩短数据处理时间,提高数据处理的效率。
数据采集
  • 用途:在实时系统中,使用线程池可以用于处理周期性或突发性的任务。例如,在嵌入式实时操作系统中,可以使用线程池来管理传感器数据的采集和处理任务。
  • 优势:线程池可以提供稳定的响应时间,确保任务在预定的时间内完成,从而满足实时系统的要求。

使用特权

评论回复

相关帖子

发新帖 我要提问
您需要登录后才可以回帖 登录 | 注册

本版积分规则

认证:苏州澜宭自动化科技嵌入式工程师
简介:本人从事磁编码器研发工作,负责开发2500线增量式磁编码器以及17位、23位绝对值式磁编码器,拥有多年嵌入式开发经验,精通STM32、GD32、N32等多种品牌单片机,熟练使用单片机各种外设。

489

主题

3830

帖子

47

粉丝