hawtdispatch

I made a working implementation. Do you want to review? Am Dienstag, 17. Dezember 2013 21:24:10 UTC+1

Hi Oliver, Just create your own ThreadPool and pass the long running task to be executed on those

Hello, I assembled some few classes now to get this accomplished. It is here on GitHub. Some use

Thanks, that did it :-). Looks now like this and runs also fine: import org.fusesource.hawtdispatch._

isExecuting returns true if it's executing on the current thread. The only way you can do that is

Yes. The "is executing" guard is specific to "is executing on current thread". On

Already tweeted it! On Tuesday, June 25, 2013, wrote: Okay, it got accepted at java.dzone.com: http:/

Thanks Christian Posta and Hiram Chirino very much！ 在 2013年6月25日星期二UTC+8上午11时18分49秒，christian.posta写道

I don't think anyone has built one yet. On Saturday, June 15, 2013 7:01:31 AM UTC-4, 金剑 wrote: Hi

Maybe in your listener, you can try doing transport.resumeRead() ? When you do transport.start() it

Hello Hiram, thanks for your reply. The lock contention caused by the QueueManager will be a problem.

Still debugging. I have modified source code to force the workaround. But now I have discovered that

Hi Hiram, thanks for pointing me to the sample. I really don't understand how it works. In my

Should be fixed now. Thanks! On Fri, Nov 16, 2012 at 4:00 PM, Saxo <jet...@web.de> wrote:

If you don't mind using non-public API's... it's: DispatcherConfig.getDefaultDispatcher()

I believe that's correct. You should be able to call resume from a different thread. If I believe

Awesome, thanks for this helpful info. On Thursday, June 28, 2012 3:28:08 PM UTC-7, christian.posta

Hi! On Tue, May 22, 2012 at 4:08 AM, Christopher Hunt <hun...@gmail.com> wrote: Hey there, I

You get a fix size thread pool for each dispatch priority being used. The threads in each pool will

Hi, stompjms 1.6 hawtdispatch 1.6 hawtbuf 1.8 (the latest from maven I hope). Il giorno sabato 17

Although I don't completely understand why the previous version didn't work, this seems to be

Good catch. Pushed fix. Thanks! On Mon, Feb 20, 2012 at 10:24 AM, Ricardo Padilha <ricardospadilha

Hi Jon, If you want to try pinning a connection to a random thread queue try this: DispatchQueue[]

That's a good question. In general I think we should integrate it too. At least so that you can

BTW- I know there's an error in the test class. I typoed the variable name. The createSource()

I had continuations enabled in my sbt Project class. That's what was causing the CPU spike. I

Hi Jon, Serial dispatch queues execute their tasks on only one thread at a time, but my get moved

Hi, I'm implementing a very high concurrency server and I'm noticing that for heavy loads a

OK. Thanks for this clarification. No need to worry then ;-)

Thanks, I'll check activemq-apollo and stomp-benchmark. On Thu, Mar 17, 2011 at 4:15 PM, Hiram