'if __name__ =='后面的任何内容__main__“：'不执行

Question

所以，这是我的情况。

我在Eclipse中使用PyDev，Windows中的Python解释器版本2.7.2。

我正在使用内置的多处理库试图分离出一堆进程来并行化一个非常计算密集型的循环。我看了看教程说来使用，

if __name__ == "__main__": 

，以防止它产卵关闭接近无限的流程和把我的系统瘫痪，本质上。

问题是，我从一个模块调用它，而不是我的主脚本;因此，在EVER执行后没有任何东西。完全没有并行的机会。当然，如果我删除它，我会收到杀死执行代码的机器的infiniprocess垃圾邮件。

作为参考的缘故，这里的相关代码：

from tribe import DataCache 
from tribe import WorldThread 
from tribe import Actor 
from time import sleep 
import multiprocessing 

class World: 
def __init__(self,numThreads,numActors,tickRate): 
    print "Initalizing world..." 
    self.cache = DataCache.DataCache() 
    self.numThreads = numThreads 
    self.numActors = numActors 
    self.tickRate = tickRate 
    self.actors = [] 
    self.processes = [] 
    for i in range(numActors): 
     self.actors.append(Actor.Actor("test.xml",self.cache)) 
    print "Actors loaded." 
def start_world(self): 
    print "Starting world" 
    run_world = True; 
    while run_world: 
     self.world_tick() 
     sleep(2) 

def world_tick(self): 
     if __name__ == '__main__': 
      print "World tick" 
      actor_chunk = len(self.actors)/self.numThreads 
      if len(self.processes)==0: 
       for _ in range(self.numThreads): 
        new_process = multiprocessing.Process(WorldThread.WorldProcess.work, args=(_, self.actors[_*actor_chunk,(_+1)*actor_chunk])) 

而且它调用类：

class WorldProcess(): 
def __init__(self): 
    print "World process initilized." 
    ''' Really, I'm not sure what kind of setup we'll be doing here yet. ''' 
def work(self, process_number, actors): 
    print "World process" + str(process_number) + " running." 
    for actor in actors: 
     actor.tick() 
    print "World process" + str(process_number) + " completed." 

我是在我的评估纠正，如果整个名 ==“主要“：只有在可执行脚本本身包含它时才检查是否有效？如果是这样，你如何安全地从模块中分离进程？如果没有，为什么它不在这里工作？

Answer 1

要控制的过程的量，使用Pool类从multiprocessing：

from multiprocessing import Pool 
p = Pool(5) 
def f(x): 
    return x*x 
p.map(f, [1,2,3]) 

（编辑：如每评论，这对于池类只是HOWTOsee更多）

使用__name__不是必需的，因为您明确地通过Process实际python函数运行。

此：

def world_tick(self): 
    if __name__ == '__main__': 
     print "World tick" 
     actor_chunk = len(self.actors)/self.numThreads 
     if len(self.processes)==0: 
      for _ in range(self.numThreads): 
       new_process = multiprocessing.Process(WorldThread.WorldProcess.work, args=(_, self.actors[_*actor_chunk,(_+1)*actor_chunk])) 

是非常糟糕的。简化它。

一个更好的方式将是：

class WorkArgs(object): 
    ... many attributes follow ... 

def proc_work(world_thread, work_args): 
    world_thread.WorldProcess.work(work_args.a, work_args.b, ... etc) 

p = Pool(5) 
p.map(proc_work, [(world_thread, args0), (world_thread, args1), ...]) 

希望这有助于！

作为一个便笺，酸洗您的论点并将它们传递给其他进程将导致导入您的模块。所以，最好确保你的模块不会执行任何分叉/魔术/工作，除非它被告知（例如，只有函数/类定义或魔术，而不是实际的代码块）。

Answer 2

添加此作为一个答案，因为它是在注释：

if __name__ == "__main__"是你在那将是一个入口点的脚本的根级别做一些事情。它是一种只有在脚本直接执行时才能做的事情。

如果你有一个脚本，它的入口点，你的名字==主。在一个你想要多进程的模块中，你只需循环和启动你的进程就像循环和启动线程一样。