consumer

0熱度

1回答

我正在爲我的操作系統課程做一個CPU調度模擬器項目。該程序應該由兩個線程組成：生產者線程和消費者線程。生產者線程包括在系統中生成進程的生成器以及選擇多個進程並將其放入稱爲緩衝區類型爲ReadyQueue的Object（由消費者和生產者共享的對象）的長期調度程序。消費者線程包括短期調度程序，它從隊列中獲取進程並啓動調度算法。我編寫了整個程序，沒有使用線程，但它的工作正常，但現在我需要添加線程，而且我

0熱度

1回答

哪個客戶端從一個隊列接收消息

如果我有一個消息隊列，並且嘗試經由 sess.receive(); 從這個隊列接收消息，其clientprogram實際上將接收該消息的多個獨立的程序？這是如何決定的？謝謝

6熱度

1回答

駱駝文件消費者模板 - 線程仍然活着

我有一個非常類似於http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.html的問題。如何殺死不同端點上的駱駝鎖定線程？我嘗試刪除端點並在設置doneUoW後停止ConsumerTemplate，但這些都不起作用。

0熱度

1回答

來自ActiveMQ中消費者的致謝

我想在消息經過某些處理引擎（如雅虎）的處理之後確認消息！ S4。我只能使用適配器將消息發送到引擎。目前我正在將每條消息存儲在適配器中，直到處理引擎將消息的JMScorrelationID返回給我，並告知消息已被處理。但是這在適配器上佔用了很多空間來存儲每條消息。那麼有什麼辦法可以使用JMScorrelationID手動創建確認並將其發送給代理？

1熱度

1回答

c＃web服務消耗錯誤

我試圖從.NET C＃項目中使用下面的WSDL來使用Web服務。我添加Web引用等，並試圖調用方法（getPatients），但它始終返回一個錯誤： "MyService.PatientType[] PatientService.getPatients(MyService.getPatients getPatients1)" "No overload for method 'getPatien

0熱度

2回答

未訂購Flex BlazeDS客戶

我的flex前端使用BlazeDS/Tomcat來收集實時數據。我正在使用標準流媒體amf頻道的普通消費者。 <mx:ChannelSet id="channelSet"> <mx:StreamingAMFChannel id="streamingAMF" url="messagebroker/streamingamf/" /> </mx:ChannelSet> <mx:Consumer

2熱度

2回答

JMS - 一個隊列和很多接收者（消費者）

我有一個由第三方發佈的JMS隊列。我想在不同的機器上設置多個使用者，只有一臺特定的機器使用者，確認該隊列上的消息。簡而言之，如果特定機器的消費者沒有收到消息，那麼不應該從隊列中刪除該消息。這是可以實現的嗎？

7熱度

1回答

當生產者也是消費者時，如何在生產者/消費者模式中使用阻止收集 - 如何結束？

我有一個遞歸問題，其中消費者在樹的每個級別上執行一些工作，然後需要遞歸樹並在下一級執行相同的工作。我想使用ConcurrentBag/BlockingCollection等並行運行。在這種情況下，隊列的使用者也是隊列的生產者！我的問題是這樣的：使用BlockingCollection，我可以寫很簡單的foreach邏輯出隊的項目，排隊新的 - 當隊列爲空，阻塞集合將正確地阻止，並等待新的工作由

1熱度

1回答

檢測到受損的oauth消費者密鑰/祕密？

我正在開發一個使用oauth的谷歌服務的android應用程序。我想知道是否有任何方法檢測我的消費者密鑰/密碼是否已經泄露，以便我可以根據需要採取措施？

7熱度

2回答

BlockingCollection多個消費者

我有以下代碼與一個生產者線程和多個消費者線程。你知道多個消費者是否線程安全。例如，是否有線程1消耗的可能性，並且線程2並行使用並更改線程1中使用的項目的值？ namespace BlockingColl { public partial class Form1 : Form { public Form1() { InitializeComponent();