RMW*_*aos 1 python multithreading wxpython nonblocking multiprocessing
Python 2.7.3 x64 wxPython 2.8 x64
已经阅读了很多关于python线程和多处理的内容,特别是Doug Hellmann撰写的一些文章,这些文章有很大的帮助.但是,我对一件事感到困惑......
我认为 Python多处理模块或多或少是线程模块的直接替代品,除了args必须是可选择的,但我发现为了不阻止我的GUI,我必须首先创建一个新的线程使用threading.Thread然后使用multiprocessing.Process在该线程中进行多进程.这很有效,而且效果很好,但对我来说似乎有点笨拙.
如果我尝试在没有第一次线程的情况下直接进行多处理,那么我的GUI仍会阻塞,直到多处理作业完成.这是按设计工作,还是我遗漏了多处理模块的基本原理?
如果需要示例,我可以提供它们.
谢谢,
-RMWChaos
要求一个例子......
假设onProcess()由GUI中的按钮触发,这会阻止GUI ...
import time
import multiprocessing as mp
def myWorker(a, b):
time.sleep(0.1)
print '{} * {} = {}'.format(a, b, a*b)
def onProcess(event):
jobs = mp.cpu_count() * 2
a = 5
b = 10
for job in range(jobs):
mp.Process(target = myWorker, args = (a, b,)).start()
Run Code Online (Sandbox Code Playgroud)
虽然这不......
import time
import multiprocessing as mp
import threading as th
def myWorker(a, b):
time.sleep(0.1)
print '{} * {} = {}'.format(a, b, a*b)
def onProcess(event):
a = 5
b = 10
th.Thread(target = myThread, args = [a, b,]).start()
def myThread(a, b):
jobs = mp.cpu_count() * 2
for job in range(jobs):
mp.Process(target = myWorker, args = (a, b,)).start()
Run Code Online (Sandbox Code Playgroud)
多线程和多处理从根本上是不同的.
线程大部分用于i/o.当你创建一个新线程时,它包含在与你生成线程的程序相同的进程中.这意味着它与程序共享内存空间,但它们(程序和线程)不能并行运行(也可以查找GIL).
另一方面,多处理在OS级别上产生了一个新进程.这个新进程可以与预先存在的进程并行运行,但它不会与生成它的程序共享内存空间.当您想要加速的代码不是i/o相关但实际的处理器密集型计算时,这更有用.
对于一个gui,你大多想要对gui的不同部分使用线程,这样在gui的一个部分运行一些东西并不会锁定你的整个gui直到处理结束.
没有代码就很难分辨,但我相信你不应该特别需要在新线程中生成一个进程,而只是让该线程处理这个进程.但是,如果该线程需要处理密集的计算类型的处理而不是大量的i/o,那么您可能希望启动一个处理它的进程.
我相信你的大多数问题都在于误解多处理与多线程.
| 归档时间: |
|
| 查看次数: |
4325 次 |
| 最近记录: |