multiprocess

0熱度

1回答

在我的客戶端應用程序中，我使用epoll和udp套接字從服務器接收數據包。客戶端應用程序有兩個進程，p1和p2。使用此函數獲取fd的sock = socket（AF_INET，SOCK_DGRAM，0）; 在方法P1中，插座（）函數返回FD的從4 P1開始已經的fd的4,5,6,7,8等在過程P2，插座（）函數返回FD的從4開始。 P2有fd的4,5,6 現在在這兩個進程中有相同的FD但端口號

0熱度

1回答

啓動一個服務器進程，並儘快連接到它

在我的python程序中，我試圖用rpyc庫作爲一個單獨的進程啓動服務器。只要我這樣做，我想能夠連接到該服務器。由於啓動過程需要一些時間，我需要延遲連接。我需要一些關於如何做到這一點的最佳方法的建議。目前我在啓動過程後使用time.sleep（10）。假設10秒鐘就足以讓服務器進程啓動並準備好接受請求。這絕對不是萬無一失的。

2熱度

1回答

爲什麼Python多進程類不改變屬性？

#!/usr/bin/env python from multiprocessing import Process class Signprocess(Process): """docstring for SignThread""" def __init__(self): super(SignThread, self).__init__() self.

0熱度

1回答

運行在單核上的進程的多個實例

我有一個4個CPU的Linux機箱，當我運行一個進程時，它會在30分鐘內處理150萬條記錄。這裏的處理意味着從Oracle DB讀取數據，派生一些東西並在文件中寫入1.5條記錄到文件系統。我們現在計劃在此服務器上運行此進程的多個單獨實例（20）。這是否意味着，我會在30分鐘內處理20 x 1.5 = 2000萬條記錄？我看到每個內核的線程數= 1（lscpu命令）。所以我認爲這不是一個正確的

0熱度

1回答

我是否需要簽署子進程？

我們正在改變我們的Windows c＃.net 4應用程序的結構爲多進程。用戶界面位於主要的exe文件中，並生成用於執行任務的子exe文件。我們使用數字簽名（即Signtool.exe）簽署UI exe。對於Windows安全性，我是否也需要簽署子exe文件？

1熱度

2回答

在內存中沒有複製索引的多處理搜索

我必須搜索科學期刊文章的大表，以獲取某些特定文章，這些文章包含在單獨的文件中。我的方法是使用Whoosh從大表中構建搜索索引，然後搜索索引中分隔文件的每篇文章。這很好，但需要很長時間（〜2周）。所以我想通過實現多處理來加快速度，這就是我正在掙扎的地方。沒有多我的「簡單」搜索的重要組成部分如下所示： articles = open('AuthorArticles.txt', 'r', encodi

10熱度

2回答

Python的多核編程

請考慮一類如下： class Foo: def __init__(self, data): self.data = data def do_task(self): #do something with data 在我的應用程序已經包含Foo類的多個實例的列表。目標是對所有Foo對象執行do_task。第一種實現很簡單： #execute tasks

0熱度

1回答

是multiprocessing.Pool使用我所有的進程？

我的代碼獲取事件通知，我用它來處理事件。早些時候它是單線程的，但事件通知處理起來相當快。我改變了我的代碼，使用Pool進行多處理。這就是我所做的創建Pool = multiprocessing.pool(processes=4)（我可以處理最多11個核心）事件添加到池異步 - pool.apply_async(go, ["event-1"]) 這就是我所做的。以簡單的方式，我將事件添加到池中，

1熱度

1回答

pthread進程共享互斥死鎖

我在共享內存上使用進程共享pthread_mutex_t。我想知道如果一個進程鎖定互斥鎖並以某種方式退出，會發生什麼？正如我的實驗所示，僵局發生了，但這是一個壞消息。那麼有沒有辦法來防止這種情況？流程退出時不應該自動解鎖互斥鎖？

1熱度

1回答

Lamport的麪包店算法

do { choosing[i] = true; number[i] = max(number[0], number[1], …, number [n – 1])+1; choosing[i] = false; for (j = 0; j < n; j++) { while (choosing[j]); // espera que j obtenh