1

我正在使用 Python 和modbus_tk 包来轮询nPLC。每次轮询大约需要 5 秒。是否可以并行运行这些，以便无需n*5几秒钟即可获取所有数据？

我当前的代码：

for ip in ip_addresses:
    master = modbus_tcp.TcpMaster(host=ip_address)
    my_vals = (master.execute(1, cst.READ_HOLDING_REGISTERS, starting_address=15))
    return my_vals
4

2 回答 2

1

我不了解 modbus_tk，但你可以只使用线程库吗？为每个 ip 地址创建 1 个线程进行轮询。

下面是一些示例代码，可以帮助您滚动：

import threading

class Poller( threading.Thread ):
    def __init__( self, ipaddress ):
        self.ipaddress = ipaddress
        self.my_vals = None
        threading.Thread.__init__(self)

    def run( self ):
        master = modbus_tcp.TcpMaster(host=self.ipaddress)
        self.my_vals = (master.execute(1, cst.READ_HOLDING_REGISTERS, starting_address=15))


pollers = []
for ip in ip_addresses:
    thread = Poller(ip)
    pollers.append(thread)
    thread.start()

# wait for all threads to finish, and collect your values
retrieved_vals = []
for thread in pollers:
    thread.join()
    retrieved_vals.append(thread.my_vals)

# retrieved_vals now contains all of your poll results
for val in retrieved_vals:
    print val

多处理也可以在这里工作，尽管它对于这个问题来说是多余的。由于这是一个 I/O 操作，因此它是线程的理想候选者。GIL（全局解释器锁）不会减慢您的速度或任何东西，而且线程比进程更轻。

于 2014-06-06T22:51:16.013 回答
0

使用multiprocessing.imap_unordered。它允许您启动一个进程池，将作业发送到池，并在它们进入时接收结果。

这是下载一堆 URL 的示例代码：

import multiprocessing, re, subprocess, sys

CMD_LIST = [
    ["wget", "-qO-", "http://ipecho.net/plain"],
    ["curl", '-s', "http://www.networksecuritytoolkit.org/nst/cgi-bin/ip.cgi"],
    ["curl", '-s', "v4.ident.me"],
    ["curl", '-s', "ipv4.icanhazip.com"],
    ["curl", '-s', "ipv4.ipogre.com"],
]


ip_pat = re.compile('[0-9.]{7,}')
pool = multiprocessing.Pool(5)
for output in pool.imap_unordered(subprocess.check_output, CMD_LIST):
    print 'output:',output
    m = ip_pat.search(output)
    if m:
        print 'GOT IP:', m.group(0)
        pool.terminate()
        sys.exit(0)

print 'no IP found'
于 2014-06-06T22:49:17.177 回答