parallel-python

2熱度

2回答

我在集羣上繼承了使用Parallel Python進行一些科學計算的維護。使用並行Python，作業被提交給一個ppserver，在這個例子中，它與其他計算機上已經運行的ppserver進程通信，將任務分配給ppworkers進程。我想使用標準庫日誌記錄模塊來記錄提交給ppserver的函數的錯誤和調試信息。由於這些ppworkers作爲單獨的進程運行（在不同的計算機上），我不確定如何正確構建日

1熱度

2回答

在分配之前引用的局部變量'sresult'

我嘗試使用PP時遇到了多個問題。我正在運行python2.6和pp 1.6.0 rc3。使用下面的測試代碼： import pp nodes=('mosura02','mosura03','mosura04','mosura05','mosura06', 'mosura09','mosura10','mosura11','mosura12') def pptester():

3熱度

1回答

使用並行Python時，有什麼方法可以告訴作業運行在哪臺機器上？

我寫了一個簡單的程序使用並行python，並且都很好。但是，主要是爲了好奇，我想知道每個任務在哪臺機器上運行，需要多長時間。有沒有什麼辦法以編程方式獲取返回的作業的這些信息？

0熱度

1回答

對象不會死（仍然引用它，我找不到）

我使用parallel-python並在函數中啓動一個新的作業服務器。在函數結束後它仍然存在，即使我沒有將它退出函數（我使用weakref來測試它）。我想還是有一些對這個對象的引用。我的兩個理論：它啓動線程並記錄到根記錄器。我的問題：我可以以某種方式找出哪個命名空間還有對這個對象的引用。我有weakref參考。有誰知道如何分離記錄器？人們還有什麼其他的調試建議？這裏是我的testcode：

3熱度

1回答

爲什麼並行Python的工作方式？

在並行Python中，爲什麼需要將所傳遞的函數以及該作業提交調用中的變量和名稱空間所需的任何模塊進行封裝 - 保留模塊級別「全局」變量的必要性如何？（如果這一切是怎麼回事）提交功能： submit(self, func, args=(), depfuncs=(), modules=(), callback=None, callbackargs=(),group='default', globa

26熱度

5回答

並行Python：什麼是回調？

Parallel Python它在提交函數函數回調（documentation）但它似乎沒有解釋得太好。幾天前我在他們的論壇上發佈了消息，但我還沒有收到回覆。有人會解釋什麼是回調和它用於什麼？謝謝。

3熱度

3回答

構建一個程序。 Python中的類和函數

我正在編寫一個使用遺傳技術來演化方程的程序。我希望能夠將函數'mainfunc'提交給並行Python'提交'功能。函數'mainfunc'調用Utility類中定義的兩個或三個方法。他們實例化其他類並調用各種方法。我想我想要的是它在一個NAMESPACE中。所以我實例化了函數mainfunc中的一些類（也許它應該是全部）。我稱之爲Utility方法'generate（）'。如果我們要