multithreading

0熱度

1回答

我期望獲得100,000個請求，其中至少有100個請求是併發的。每當我收到請求時，我都會創建一個新線程，並在使用pthread_exit()完成後將其銷燬。使用pthread_detach我獲得99％的成功率。有沒有比這更好的方法？ pthread_t hilo; // infinite loop while ((client_sock = accept(server_sock, (struc

0熱度

1回答

在Node.js中鎖定承諾鏈接

我有一個REST API，它會一個接一個地執行一系列異步任務。代碼如下所示： asyncFunc1() .then(asyncFunc2()) .then(asyncFunc3()) .then(asyncFunc4()) 第一步將執行一些數據庫查詢，最後一步將更新數據庫。當然（因爲我來自java/c + +背景），我會在我的承諾鏈的開頭添加一個鎖，以確保與數據庫的交互受到保護。但我是

0熱度

1回答

Python中的並行或事件驅動函數？

我對Python相當陌生，所以也許我應該如何工作的整個概念是錯誤的：我正在爲時間管理目的構建RFID閱讀器。例如。用戶使用RFID芯片登錄 - >計時器開始每隔一分鐘計算並更新Google電子表格。更新部分工作正常，但需要一段時間。但我想一直檢查RFID登錄。我讀過的地方就是我正在尋找的事件驅動編程。目前我正在做一切在一段時間的真正的循環，這感覺就像一個黑客本身。我能以某種方式在RFID閱讀器

0熱度

2回答

從LinkedBlockingQueue中刪除元素時，我的下面的代碼線程安全嗎？

我有一個下面的方法，它被多個線程同時調用來獲取活動套接字。它需要LinkedBlockingQueue作爲參數，然後我迭代，看看是否有liveSocket可用，如果它可用，然後我刪除並返回該套接字。 private Optional<Holder> getSocket(final LinkedBlockingQueue<Holder> endPoints) { Optional<Hold

0熱度

3回答

是否從MainActivity和碎片複製線程開始服務？

我從MainActivity以及Fragment開始後臺服務。它會創建重複線程嗎？所以這將是2服務運行？ MainActivity protected void onCreate(Bundle savedInstanceState) { //... context.startService(new Intent(context,gps_service.class)); //

1熱度

1回答

瓶服務器退出時線程仍然運行

正如標題所述，我創建了一個單獨的線程來執行Flask中的長任務。 import schedule import time start_time = time.time() def job(): print("I'm working..." + str(time.time() - start_time)) def run_schedule(): while Tr

0熱度

3回答

當數據準備就緒時，從改造的警報Mainthread

我有一個改造請求，當我在onResponse中獲取數據時，我在上面的代碼中稱爲繁重工作的文本視圖中插入了倍數，我從OnReponse得到結果，否則我會從數據庫中得到結果，所以問題是我在OnResponse和OnFailure中有相同的代碼，所以有任何方法可以將我繁重的工作放在改進之外，並等待響應只從OnResponse或OnFailure獲得一個結果？ call.enqueue(new Call

0熱度

2回答

Java的揮發性，同步，原子例如

您好我正在讀Java併發在實踐中，我讀有趣的說法指出，鎖定既能保證可見性和原子;易變的變量只能保證能見度。任何一個可以請解釋，如果變量聲明爲揮發性所有其他線程讀取更新獲得價值那就是爲什麼我關心像聲明中的原子：counter = counter + 1; 在此先感謝。

1熱度

1回答

Python的多線程服務器可以在同一時間

我玩弄瞭解多線程處理一個客戶端的消息，所以我寫了下面的客戶機/服務器應用程序，其中，服務器發送命令給客戶端，客戶端檢查此命令，如果它等於到'a'它發送一個回覆到服務器。在我創建了兩個插槽和一個線程的服務器代碼;第一個套接字將命令發送（發佈）到所有連接（訂閱）的客戶端。在線程第二插座等待來自客戶的任何答覆，但因爲線程執行一些阻塞的操作（如存儲客戶端在數據庫中發送的信息），它可以在同一時間，即使插座

0熱度

2回答

RxJava和一些編碼與rxjava它讓你想在一個完全不同的方式，我仍然無法理解我應該怎麼做時，我想要一些操作的一些數據保存在集合中（後收藏

保存數據可以說地圖的一個關鍵的價值），以便在所有請求完成後稍後處理。例如可以說我想發出一些對某個API的調用，並在地圖中保存所有失敗的調用響應，以便稍後進行一些「錯誤更正」。直到現在它看起來像我需要從上到下寫整個流程來做這個請求 - >錯誤 - >糾正這是一個操作管道，我想分離到兩個不同的操作發生在不同的時間。我意識到我可能錯過了rxjava的一個關鍵概念。總之我怎麼之外緩存數據的集合在以