python-multiprocessing

0熱度

1回答

的Python：並行執行pysphere命令

我對環路電流不分級1移除快照從我16個虛擬機 for vmName in vmList: snapshots = vmServer.get_vm_by_name(vmName).get_snapshots() for i in range(len(snapshots)-3): snapshotName = snapshots[i].get_name()

python multiprocessing python-multiprocessing pysphere 2017-02-03

---

0熱度

1回答

在現有數組周圍創建共享內存（python）

無處不在我看到用於python的共享內存實現（例如，在multiprocessing中），創建共享內存始終分配新內存。有沒有辦法創建一個共享內存對象，並讓它引用現有的內存？目的是爲了預先初始化數據值，或者說，如果我們已經擁有了一個數組，例如避免必須複製到新的共享內存中。根據我的經驗，分配一個大的共享數組要比將值複製到其中更快。

python shared-memory python-multiprocessing 2017-02-04

---

0熱度

1回答

使用對象進行多處理？

考慮下面的代碼： if __name__ == '__main__': print "name = main" multiprocessing.Process(target=r.fetchFiles, args=(r.results.pop(),)) class R: # ... def fetchFiles(self, blabla): w

python python-multiprocessing 2017-02-14

---

1熱度

1回答

python遞歸算法多進程

我想在python 2.7中使用一個工作者池和一個管理器在進程間共享一個隊列的代碼多進程遞歸算法。 條帶化了所有的算法細節的代碼看起來像以下之一： from functools import partial from multiprocessing import Pool, Manager def pulse(l, c, accOut, v): print l, c, v

python recursion python-multiprocessing 2017-02-15

---

0熱度

1回答

多進程兔子消費者

在此先感謝。 我是多處理新手。 我已經創建了一個流程，通過它我想同時使用數據槽Rabbit MQueue，但它一次運行一個進程。 def start_consum(queue_name): channel.basic_consume(func, queue=queue_name) channel.start_consuming() def process_start(num

multithreading python-2.7 rabbitmq python-multiprocessing pika 2017-02-15

---

1熱度

1回答

多處理不起作用計算矩陣的叉積

我想比較非並行版本和並行版本函數的運行時間。問題在於，儘管並行函數適用於線程包，但在切換到多處理包後，這些進程永遠不會啓動。我想知道這是否是由我的編譯器或其他任何東西引起的。任何人都可以運行我的代碼，看看它是否在其他環境中工作？如果沒有，我的代碼中有什麼問題？ import numpy as np from multiprocessing import Process def single_

python python-2.7 multiprocessing python-multiprocessing 2017-02-15

---

2熱度

1回答

導入錯誤：沒有模塊名爲「multiprocessing.forking」

我運行的Python 3.5，並試圖運行從this django app在命令行中一些代碼，這已經發生的事情： C:\Users\username\Envs\mysite> python service.py --startup=auto install Traceback (most recent call last): File "service.py", line 14, in

python django python-multiprocessing 2017-02-16

---

0熱度

1回答

Python在父進程和子進程之間共享帶有Event（）變量的字典

我想在父進程和子進程之間共享一個帶有一些Event（）變量的字典，但不知道如何。請注意，我需要在進程啓動後添加或刪除（鍵值）。似乎下面的正常詞典和多處理.Manager.dict都不能滿足我的要求。 import time from multiprocessing import Process, Event, Manager manager = Manager() d1 = manager

python semaphore python-multiprocessing 2017-02-17

---

0熱度

1回答

如何修改一個線程中的變量並在另一個線程中檢查它？

下面是演示問題的代碼。請注意，這只是一個例子，我在一個更復雜的應用程序中使用了相同的邏輯，我不能使用sleep作爲時間量，它需要process1來修改變量，取決於速度互聯網連接。 from multiprocessing import Process code = False def func(): global code code = True pro = Pro

python multiprocessing race-condition python-multiprocessing 2017-02-19

---

0熱度

1回答

如何取消使用`concurrent.futures.ProcessPoolExecutor`運行的長時間運行的子進程？

您可以看到完整的here。 我的代碼的簡化版本如下： executor = ProcessPoolExecutor(10) try: coro = bot.loop.run_in_executor(executor, processUserInput, userInput) result = await asyncio.wait_for(coro, timeout=10.0,

python python-multiprocessing python-asyncio 2017-02-19

---