如何清空列表代理的内容

11 投票
2 回答
9351 浏览
提问于 2025-04-18 05:34

我该如何清空一个共享的多进程管理器列表?在下面的例子中,我想在循环继续之前清空它,这样新创建的进程就能找到一个空列表。

num_consumers = multiprocessing.cpu_count() 
p = multiprocessing.Pool(num_consumers)
manager = multiprocessing.Manager()
mp_list = manager.list()

def put_some_data(data):
    #Processing occurs and then we append the result
    mp_list.append(data)

def do_some_processing():
    While True:
        #Multiprocessing runs here
        result = p.map(put_some_data, data)
        mp_list.clear()
        #When done, break

上面的代码会报错 AttributeError: 'ListProxy' object has no attribute 'clear'

关于如何清空这个代理列表对象,文档上并没有解释得很清楚()

2 个回答

1

仅供参考

del mp_list[:]

还有

mp_list *= 0

这个方法也能用,但被认可的答案可能是最简洁的解决方案。

34

这是我处理这个问题的方法。用列表推导来解决!

>>> import multiprocessing
>>> m = multiprocessing.Manager()
>>> lst = m.list()
>>> lst.append(0)
>>> lst.append(1)
>>> lst.append(2)
>>> lst
<ListProxy object, typeid 'list' at 0x3397970>
>>> lst[:]
[0, 1, 2]
>>> lst[:] = [] 
>>> lst
<ListProxy object, typeid 'list' at 0x3397970>
>>> lst[:]
[]
>>>

所以

>>> lst[:] = []

这样做可以哦 :)

撰写回答