consumer

    2熱度

    1回答

    檢測到重複的基於HTTP的FlexSessions，一般是由於遠程主機禁用會話cookie

    場景描述： 我的程序是Flex + Java的+ BlazeDS的+ ActiveMQ的實現，它由Flex消費者訂閱從ActiveMQ的JMS消息，目前我在 提供了兩個tomcat服務器，它們都包含我的程序，而ActiveMQ是在另一個服務器上，現在我在同一種瀏覽器中打開兩個應用程序，比如IE或Chrome等 ，無論如何，url就像http：// localhost： /HelloWord/ind
    flex session jms blazeds consumer 2013-01-10

    1熱度

    1回答

    C＃.Net 2.0 .NET 4.5 TPL生產者消費者邏輯的線程池等效

    在我的應用程序中，我有一組預定義的動作。我想指定特定數量的線程來執行這些操作。由於某些操作可能比其他操作花費更長時間，並且可能正在等待響應，所以當線程完成時，我希望它返回隊列並開始下一個操作。所以，作爲十個線程之一釋放，它會得到一個新的動作，等等，直到隊列爲空，然後繼續。在繼續之前，我需要等待所有的動作完成。 所以我做了一些使用TPL的研究和測試，它在記憶之前工作得很好，「哦，廢話，我僅限於.Ne
    c# multithreading task-parallel-library threadpool consumer 2013-01-11

    0熱度

    3回答

    消息消費者實現

    我猜消息的消費者應該始終傾聽，或者應該設置批處理來經常檢查和使用消息。 當我們做基本的例子時，我們使用獨立的java程序繼續運行。我們如何在任何應用服務器（如JBoss）的真實世界Web應用程序中實現它們？比方說，我們使用Spring MVC，Hibernate和JBoss。它通常如何實現/設置它，以便它繼續運行並使用消息？ （生產者可以是任何網頁時，按一下按鈕或諸如此類的東西） 可能是非常基本的
    spring jboss jms implementation consumer 2013-03-08

    0熱度

    1回答

    僵局生產者消費者

    I have following classes : package com.akshu.multithreading; public class ThreadResource { static int a; static boolean Value =false; public synchronized int getA() {
    java consumer producer 2013-03-17

    1熱度

    1回答

    akka駱駝消費者的autoAck是什麼意思？

    autoAck在akka駱駝消費者返回布爾值true或false。 如果autoAck = true，當消息進入消費者的郵箱但消費者處理消息之前，消費者該怎麼做？
    akka consumer 2013-02-04

    0熱度

    1回答

    在處理消息或處理完消息之前做了akka駱駝消費者出隊消息嗎？

    class MyConsumer1 extends Consumer { def endpointUri = "some protocol string" def receive = { case msg: CamelMessage ⇒ // processing msg } } MyConsumer1是駱駝消費者的一般形式。 問題： msg in
    message akka consumer 2013-02-04

    0熱度

    1回答

    定期阿卡演員和駱駝消費者演員之間有什麼區別？

    一個常規的Akka actor與一個郵箱和dispather（線程池）相關聯，可以通過配置或編程設置。你可以通過路徑查找普通演員。 正規演員先出隊郵件形式郵箱先處理郵件等 我可以對駱駝消費者演員做同樣的事嗎？ 正規演員和駱駝消費者演員之間有什麼區別？
    akka actor consumer 2013-02-05

    1熱度

    2回答

    單文件閱讀器/多用戶模型：多線程程序的好主意？

    我有一個簡單的任務，很容易並行。基本上，必須在（大，幾個Gb）輸入文件的每一行上重複執行相同的操作。雖然我已經做了一個多線程版本，但我注意到我的I/O是瓶頸。我決定構建一個實用程序類，它涉及一個簡單的「文件讀取器」線程，它可以直接向前讀取並儘可能快地讀入循環緩衝區。然後，多個消費者可以打電話給這個班級並獲得他們的「下一行」。給定n個線程，每個線程我的起始行是文件中的第i行，並且通過添加n找到該線程
    multithreading io consumer producer 2013-02-05

    7熱度

    1回答

    RabbitMQ消費者點播？

    我希望消費者每次收到消息時都執行一些操作。消費者必須全天候地「聆聽」隊列，還是隻能在收到適當的消息時才運行？
    rabbitmq consumer 2012-11-05

    0熱度

    1回答

    生產者線程卡住但未阻塞

    根據JConsole堆棧跟蹤，我有一個生產者 - 消費者線程集，但生產者陷入不是.put()的一行代碼中。 class Producer implements Runnable { private final BlockingQueue<CopyOnWriteArrayList<Creature>> queue; private World myWorld; Pro
    java multithreading consumer producer 2013-02-17
最新問題