Python使用modbus_tk利用线程池实现多个设备的不同读写

要使用modbus_tk库实现多个设备的不同读写操作，并使用线程池来提高执行效率，可以参考下面的示例代码：

import modbus_tk.defines as cst
import modbus_tk.modbus_tcp as modbus_tcp
import concurrent.futures

def read_write(device, operation, address, value=None):
    # 创建Modbus TCP主机连接
    master = modbus_tcp.TcpMaster(host=device)

    # 根据操作类型执行不同的读写操作
    if operation == 0:
        # 读取数据
        data = master.execute(1, cst.READ_HOLDING_REGISTERS, address, 1)
        return (device, 'Read', address, data[0])
    elif operation == 1:
        # 写入数据
        master.execute(1, cst.WRITE_SINGLE_REGISTER, address, output_value=value)
        return (device, 'Write', address, value)

devices = {'device1': '192.168.0.1', 'device2': '192.168.0.2'}
address_list = [0, 1, 2, 3]

with concurrent.futures.ThreadPoolExecutor(max_workers=len(devices)) as executor:
    # 提交读操作到线程池中
    futures = []
    for device in devices.values():
        for address in address_list:
            future = executor.submit(read_write, device, 0, address)
            futures.append(future)

    # 获取所有操作的结果
    for future in concurrent.futures.as_completed(futures):
        result = future.result()
        print(result)

    # 提交写操作到线程池中
    futures = []
    for device in devices.values():
        for address in address_list:
            future = executor.submit(read_write, device, 1, address, value=123)
            futures.append(future)

    # 获取所有操作的结果
    for future in concurrent.futures.as_completed(futures):
        result = future.result()
        print(result)

在上面的示例代码中，read_write函数创建了一个Modbus TCP主机连接，并根据操作类型执行不同的读写操作。在主程序中，使用executor.submit()方法将读操作和写操作分别提交到线程池中，并将返回的future对象添加到futures列表中。然后使用concurrent.futures.as_completed()方法获取所有操作的结果并打印出来。其中，address_list是要读写的寄存器地址列表。