producer-consumer

2熱度

2回答

我發現這個code在代碼審查堆棧交換，它實現了生產者 - 消費者問題。我在這裏發佈一段代碼。在給定的代碼，讓我們考慮一個場景時，製片人致電void add(int num)產生價值，它獲取的是互斥鎖mu和buffer.size()==size_這使得在等待隊列中的生產者進入，由於條件變量cond。同時發生上下文切換並且消費者調用函數int remove()消耗值，它嘗試獲取互斥鎖mu上的鎖，但

1熱度

1回答

C管道：錯誤的文件描述符

我有簡單的生產者消費者程序在C嘗試用fork解決它生產者試圖在管道上寫入時我得到錯誤：我已經寫了另一個程序具有相同的邏輯，但這一個不知道爲什麼？生產者未能寫管道項目：爲什麼我得到這個錯誤，錯誤的文件描述符任何人有想法？由於 #define READ 0 #define WRITE 1 int mutex = 1, full = 0, empty = BUFFER_SIZE, x =

0熱度

1回答

如何使用kafka-avro-console-producer？

如果我使用'kafka-console-producer' - 它會自動拾取JASS文件並正常運行（可以產生遠程主題）。如果我使用「卡夫卡的Avro控制檯生產者」與完全相同的配置但增加了架構屬性 - 它抱怨JASS配置： 'Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.s

1熱度

2回答

AWS設備農場「運行Calabash測試後沒有發現要執行的套件」

我試過用幾種不同的方式提交測試，但不斷收到此錯誤。有人有主意嗎？下面是我在提交我的測試格式。 mytests.zip -features - step_definitions - steps.rb - moresteps.rb - support - app_installation_hooks.rb - app_lif

2熱度

4回答

如何避免dcast（）輸出中的NA列？

如何避免NA列dcast()從reshape2封裝輸出？在該虛設示例的dcast()輸出將包括NA柱： require(reshape2) data(iris) iris[ , "Species2"] <- iris[ , "Species"] iris[ 2:7, "Species2"] <- NA (x <- dcast(iris, Species ~ Species2, value

0熱度

1回答

如何使用OpenMP在C++中實現監視器？

我正在使用C++編寫Producer-consumer problem以及在使用OpenMP時如何實現顯示器？我無法找到像OpenMP中conditional_variable任何東西，我不能執行等待/通知上像維基百科例如某些條件。

0熱度

3回答

URL重定向issue.in asp.net mvc

當我創建一個新的記錄時，我試圖用這個重定向到編輯頁面。 return RedirectToAction("Edit", "Organization", new { OrgId = organization.OrgId }); 但是，結果是這樣的。 http://localhost:1626/Organization/Edit?OrgId=5 當它應該是 http://localhost:1

2熱度

1回答

TCP套接字服務器的CPU時間超過限制'

這個問題提出了運行使用生產者/消費者設計創建了一個socket服務器的同時，程序日誌，錯誤cpu time limit exceeded墜毀。我還發現，cpu使用率超過90%的時間。這裏是服務器的代碼，它可能會出錯，我該如何優化？我用這個方法queue以避免爲每個請求的那麼多的threads創建。在主方法（主線程） //holds socket instances ConcurrentLin

0熱度

1回答

工人阻止消費 - RabbitMQ - Node.js

我在Node.js中遇到了RabbitMQ問題。我試圖實現一個Pub/Sub連接器，其中每個用戶都有自己的隊列輪詢以獲取消息。當我通過Postma發佈郵件並且用戶使用郵件時，我沒有任何問題（我正確地獲取郵件），而如果用戶試圖使用隊列中的郵件（但不存在郵件），它會一直卡住，直到發佈了新的發佈，但我無法獲得該消息。我想要做的是放棄消耗，然後重試。你能幫我解決嗎？ get_queue工作正常，並

0熱度

1回答

One Producer十個消費者文件處理與Executors.newSingleThreadExecutor（）

我有一個LinkedBlockingQueue任意挑選的容量爲10，並有1000行輸入文件。據我所知，我在服務類的main方法中有一個ExecutorService類型變量，它使用Executors.newSingleThreadExecutor() - 一個單獨的線程調用buffer.readline（），直到文件line == null，然後處理 - 在循環使用Executors.newSin