代码之家 › 专栏 › 技术社区 › Peter Smit

Python多处理/线程,共享变量只能读取

multiprocessing multithreading python

Peter Smit · 技术社区 · 15 年前

既然在解决这个问题时似乎没有什么困难的事情,那么如何才能在Python中做到最好呢?我想用一个游泳池来确保一次只进行三个实验。我应该使用多重处理吗?如果是的话,最短最简洁的是什么?

#!/usr/bin/env python2.6
import time

class Model:
    name = ""
    def __init__(self,name):
        self.name = name

class Experiment:
    id = 0
    model = None
    done = False

    def __init__(self,id,model):
        self.id = id
        self.model = model

    def run(self):
        for _ in range(0,60):
            print "Hey %s from experiment %d" % (self.model.name, id)
            time.sleep(1)
        self.done = True


if __name__ == "__main__":
    experiments = []
    model = Model("statictistical model")
    for i in range(0,5):
        experiments.append(Experiment(i, model))

    #How to run 3 experiments at the same time

2 回复 | 直到 15 年前

Vin-G 15 年前

检查文件,具体如下:

http://docs.python.org/library/multiprocessing.html#module-multiprocessing.pool

#!/usr/bin/env python2.6
import time
import multiprocessing

class Model:
    name = ""
    def __init__(self,name):
        self.name = name

def run_experiment(id, model):
    print "Experiment %d is starting" % id
    for _ in range(0,60):
        print "Hey %s from experiment %d" % (model.name, id)
        time.sleep(1)
    print "Experiment %d is done" % id
    return "Result for %d" % id


if __name__ == "__main__":
    model = Model("statictistical model")
    experiments = ((i, model) for i in range(0, 5))
    pool = multiprocessing.Pool(3)

    results = [pool.apply_async(run_experiment, experiment) for experiment in experiments]
    for result in results:
        r = result.get()
        # do something with r
        # or nothing, i suppose...

也要注意文档中关于使用 multiprocessing 模块:

此软件包中的功能要求 __main__ 孩子们喜欢的。这是包含在编程指南中然而,这里值得指出。这意味着一些例子,例如这个 multiprocessing.Pool 示例在交互模式下不起作用口译译员

xyz-123 15 年前

您必须始终记住,线程并不是真正并行运行的,如果这是您真正想要的。

我不明白真正的问题是什么。。。?如果您只希望3个线程同时运行,为什么不只启动3个线程呢?

推荐文章

Bass · @Volatile lateinit变量可以在Kotlin中使用DCL模式进行原子初始化吗?

5 月前

bepopov · 无法在继承的Thread类中将值设置为Inheritable ThreadLocal字段

6 月前

Starnec · Anticapte FileHooser关闭以中止正在运行的任务

6 月前

user107586 · 如何处理等待句柄不会导致无限循环?

6 月前

ron burgundy · 获取-释放语义是否跨线程传递?[副本]

6 月前

BenjiFB · C#内存缓存:在一次操作中追加到列表?

6 月前

Adam Rutledge · 让父线程在初始化子线程pthread后等待,直到它从子线程接收到一些信号的最佳方法是什么?

7 月前

András Takács · Python多线程问题

10 月前

András Takács · Python多线程错误

10 月前

eden sson · 使用std::thread和native_handle()设置线程关联掩码

11 月前