由于其并发 futures 模块,我刚刚开始使用 Python3 。我想知道能否让它检测错误。如果有更高效的模块,请告诉我,因为我想使用并发 futures 进行并行编程。
我不喜欢 multiprocessing,因为它过于复杂,而且没有太多的文档说明。但是,如果有人可以使用 multiprocessing 写一个仅使用函数而非类来进行并行计算的 Hello World 程序,那将很好理解。
这是一个简单的脚本:
from concurrent.futures import ThreadPoolExecutor
def pri():
print("Hello World!!!")
def start():
try:
while True:
pri()
except KeyBoardInterrupt:
print("YOU PRESSED CTRL+C")
with ThreadPoolExecutor(max_workers=3) as exe:
exe.submit(start)
以上代码只是演示如何使用CTRL+C无法打印语句。
我想要的是,在出现错误时能够调用一个函数。这个错误检测必须来自于函数本身。
另一个例子
import socket
from concurrent.futures import ThreadPoolExecutor
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
def con():
try:
s.connect((x,y))
main()
except: socket.gaierror
err()
def err():
time.sleep(1)
con()
def main():
s.send("[+] Hello")
with ThreadPoolExecutor as exe:
exe.submit(con)
KeyBoardInterrupt
?这是你在问什么吗? - laike9m