libmodbus互斥锁（mutex）和可重入锁（recursive lock）示例

• libmodbus库提供了一些锁机制以保护在多线程环境下访问Modbus从站设备的data。具体来说，libmodbus库提供了以下两种锁机制：

1. 互斥锁（mutex）：libmodbus库中的modbus_t结构体中包含了一个互斥锁，可以使用modbus_mutex_lock（）和modbus_mutex_unlock（）函数对该锁进行加锁和解锁Operation，以保护在多线程环境下对Modbus从站
2. 可重入锁（recursive lock）：libmodbus库还提供了可重入锁机制，可以通过modbus_rtu_set_custom_rts（）函数设置用户Customization的RTSOperation回调函数，并在回调函数中加锁和解锁，以保护在多线程环境下对Modbus从站设备的访问。

需要注意的是，使用锁机制需要谨慎，因为不正确的使用会导致死锁或线程阻塞等问题，因此在多线程环境下使用libmodbus库时，需要仔细设计和实现线程同步机制。

以下是使用libmodbus库的互斥锁示例代码：

#include <stdio.h>
#include <modbus/modbus.h>

int main() {
    modbus_t *ctx;
    modbus_mapping_t *mapping;
    int ret;

    // 创建Modbus从站设备并分配data存储区
    ctx = modbus_new_rtu("/dev/ttyS0", 9600, 'N', 8, 1);
    if (ctx == NULL) {
        fprintf(stderr, "Failed to create modbus context\n");
        return -1;
    }
    mapping = modbus_mapping_new(0, 0, 100, 0);
    if (mapping == NULL) {
        fprintf(stderr, "Failed to allocate mapping\n");
        modbus_free(ctx);
        return -1;
    }

    // 加锁并访问Modbus从站设备
    modbus_mutex_lock(ctx);
    ret = modbus_connect(ctx);
    if (ret == -1) {
        fprintf(stderr, "Failed to connect to Modbus device\n");
        modbus_mutex_unlock(ctx);
        return -1;
    }
    ret = modbus_write_register(ctx, 0, 123);
    if (ret == -1) {
        fprintf(stderr, "Failed to write register\n");
        modbus_mutex_unlock(ctx);
        return -1;
    }
    modbus_close(ctx);
    modbus_mutex_unlock(ctx);

    // 释放资源并退出
    modbus_mapping_free(mapping);
    modbus_free(ctx);
    return 0;
}

以上代码中，通过调用modbus_mutex_lock（）函数加锁，然后访问Modbus从站设备，最后通过调用modbus_mutex_unlock（）函数解锁。使用互斥锁可以确保在多线程环境下，同时只有一个线程能够访问Modbus从站设备，避免了竞态条件等问题。

以下是使用libmodbus库的可重入锁示例代码：

#include <stdio.h>
#include <modbus/modbus.h>

// 定义可重入锁
modbus_t *g_ctx = NULL;
modbus_mutex_t g_lock;

// 定义用户Customization的RTS回调函数
void custom_rts(modbus_t *ctx, int on) {
    if (on) {
        modbus_mutex_lock(&g_lock);
    } else {
        modbus_mutex_unlock(&g_lock);
    }
}

int main() {
    modbus_mapping_t *mapping;
    int ret;

    // 创建Modbus从站设备并分配data存储区
    g_ctx = modbus_new_rtu("/dev/ttyS0", 9600, 'N', 8, 1);
    if (g_ctx == NULL) {
        fprintf(stderr, "Failed to create modbus context\n");
        return -1;
    }
    mapping = modbus_mapping_new(0, 0, 100, 0);
    if (mapping == NULL) {
        fprintf(stderr, "Failed to allocate mapping\n");
        modbus_free(g_ctx);
        return -1;
    }

    // 设置用户Customization的RTS回调函数并访问Modbus从站设备
    modbus_set_rts(g_ctx, custom_rts);
    ret = modbus_write_register(g_ctx, 0, 123);
    if (ret == -1) {
        fprintf(stderr, "Failed to write register\n");