Hi Eric,
I'm not sure I can answer your very broad question, would you mind/be able
to formulate a couple of more specific ones?
On Fri, Jul 3, 2015 at 6:34 PM, Eric Kolotyluk eric.koloty...@gmail.com
wrote:
I have prototyped an application that basically multiplexes messages,
assembles them into blocks, and then segments them. The application tries
to do as much concurrently as possible.
I have used something I call a 'pulse queue' which is based on a
non-blocking concurrent queue.
http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html
Basically, I create a separate future to handle the processing of each
message, and the futures complete their work by adding their results to the
non-blocking queue. The pulse part is that periodically (i.e. each second)
the queue is drained to create a block or segment. There are other reasons
to drain a queue, i.e. size, but primarily it is the pulse that keeps data
moving through the system.
I have found this to be simple to code, and effective at handling large
numbers of Futures concurrently.
As I am trying to understand Akka Streams, and Akka HTTP, I am wondering
if Streams would be a better or equivalent solution, but I do not really
understand how streams work under the hood to answer my curiosity. For
example, in the Streams environment is it possible to create a separate
future to handle each message, the way the pulse queue does? My sense is
that each element in the stream is an Actor under the hood, so that the
messages (while non-blocking) would get serialized.
Cheers, Eric
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives:
https://groups.google.com/group/akka-user
--- You received this message because you are subscribed to the
Google Groups Akka User List group.
To unsubscribe from this group and stop receiving emails from it, send an
email to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
--
Cheers,
√
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups Akka
User List group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
