python多进程问题求解

uselsee

代码如下，求高手指教

#!/usr/bin/env python
from multiprocessing import Manager
m = Manager()
d = m.dict()
d['a']=[]
d['a'].append(1)   这句无法执行，这个列表添加不了对象，不明白为什么，麻烦大侠指教

sunny7476

我这没有问题。。。

uselsee

sunny7476 发表于 2013-06-12 18:18
我这没有问题。。。

不能把，我打印出来的字典d发现这个值没有append进去啊

./t.py
{'a': []}

GhostFromHeaven

回复 1# uselsee


dict()
dict(mapping)
dict(sequence)
Create a shared dict object and return a proxy for it.
list()
list(sequence)
Create a shared list object and return a proxy for it.
Note
Modifications to mutable values or items in dict and list proxies will not be propagated through the manager, because the proxy has no way of knowing when its values or items are modified. To modify such an item, you can re-assign the modified object to the container proxy:

# create a list proxy and append a mutable object (a dictionary)
lproxy = manager.list()
lproxy.append({})
# now mutate the dictionary
d = lproxy[0]
d['a'] = 1
d['b'] = 2
# at this point, the changes to d are not yet synced, but by
# reassigning the dictionary, the proxy is notified of the change
lproxy[0] = d

uselsee

回复 4# GhostFromHeaven

能帮我看看这个段代码为啥报错吗？

#!/usr/bin/env python
import paramiko, sys, multiprocessing, time
def sshcmd(myqueue):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.load_system_host_keys()
    while True:
        ip = myqueue.get()
        ssh.connect(ip, username='root', password='xxxxxx')
        stdin, stdout, stderr = ssh.exec_command('ls -l')
        print stdout.read()
        myqueue.task_done()

if __name__  ==  '__main__':
    ips = ['10.69.12.19', '10.69.12.19']
    manager = multiprocessing.Manager()
    myqueue = manager.JoinableQueue()
    for i in ips:
        myqueue.put(i)

    for i in range(2):
        p = multiprocessing.Process(target = sshcmd, args = (myqueue,))
        p.daemon = True
        p.start()
    myqueue.join()