Python用modbus_tk线程池连接多个设备

好的，下面是一个简单的示例代码，用Python的modbus_tk库和线程池模块实现连接多个设备的读写操作：

import modbus_tk
import modbus_tk.defines as cst
from modbus_tk import modbus_tcp, hooks
import concurrent.futures

# 定义设备地址和端口号
devices = {
    "device1": {"ip": "192.168.1.1", "port": 502},
    "device2": {"ip": "192.168.1.2", "port": 502},
    "device3": {"ip": "192.168.1.3", "port": 502}
}

# 初始化modbus_tk的Master对象
def init_master(ip, port):
    master = modbus_tcp.TcpMaster(ip, port)
    master.set_timeout(5.0)
    return master

# 定义读写操作的函数
def read_write(device, address, value):
    master = init_master(devices[device]["ip"], devices[device]["port"])
    # 执行读写操作
    result = master.execute(1, cst.WRITE_SINGLE_REGISTER, address, output_value=value)
    result = master.execute(1, cst.READ_HOLDING_REGISTERS, address, 1)
    # 关闭连接
    master.close()
    return result

# 使用线程池执行读写操作
with concurrent.futures.ThreadPoolExecutor(max_workers=len(devices)) as executor:
    # 提交读写操作到线程池中
    futures = []
    for device in devices.keys():
        future = executor.submit(read_write, device, 1000, 1234)
        futures.append(future)
    # 获取所有操作的结果
    for future in concurrent.futures.as_completed(futures):
        result = future.result()
        print(result)

上面的代码中，我们首先定义了需要连接的多个设备的地址和端口号，然后使用`init_master`函数初始化了每个设备的modbus_tk的Master对象。接着，我们定义了一个`read_write`函数，用于执行读写操作。在主函数中，我们使用Python的线程池模块concurrent.futures创建了一个线程池，最大工作线程数为连接设备的数量。然后，我们循环提交读写操作到线程池中，并使用`concurrent.futures.as_completed`函数获取所有操作的结果。当然，这只是一个简单示例，具体的操作可以根据实际需求进行修改。