This is very cool Nicklas. I'd love to look at your examples. Also if you
like
it might be possible to push back your extensions of javaflow back to
commons.
Thanks this was fun to look at.
Alex
On 10/24/07, Niklas Therning <[EMAIL PROTECTED]> wrote:
>
> Hi guys,
>
> I've played around with combining commons-javaflow (continuations for
> Java) and MINA. The result is that I can do session.read() and wait for
> a new message without blocking the current thread. session.read() uses
> javaflow to suspend the current thread and save the call stack. Then
> when a new message arrives my code will be resumed right after the call
> to session.read(). session.write() and session.close() both work
> similarly.
>
> Here's a simple example I've been working on:
>
> public class Main {
>
> public static void main(String[] args) {
>
> BasicConfigurator.configure();
>
> final NioSocketConnector connector = new NioSocketConnector();
> connector.getFilterChain().addLast("pcf", new ProtocolCodecFilter(
> new TextLineCodecFactory(
> Charset.forName("ISO8859-1"),
> LineDelimiter.WINDOWS,
> LineDelimiter.WINDOWS)));
> connector.getFilterChain().addLast("log", new LoggingFilter());
> connector.setHandler(new ContinuationIoHandler(new
> ContinuableIoHandler() {
>
> @Continuable
> public void run(ContinuableIoSession session) {
> try {
> System.out.println(session.read());
> session.write("USER user");
> System.out.println(session.read());
> session.write("PASS qwerty");
> System.out.println(session.read());
> session.write("STAT");
> System.out.println(session.read());
> session.write("QUIT");
> System.out.println(session.read());
> session.close();
> } catch (IOException e) {
> e.printStackTrace();
> }
> }
>
> public void sessionCreated(IoSession session) {
> }
>
> }));
> connector.connect(new InetSocketAddress("pop.example.com", 110));
> }
> }
>
> This code will log in to a POP3 server and query it for the number of
> messages and then log out. The nice thing about this is that you get the
> best of two worlds: simple and readable code (blocking style) yet the
> scalability of non-blocking IO.
>
> If you find this interesting I'd be more than happy to put the code in
> my sandbox for you to play with. Please be aware that I've extended
> commons-javaflow slightly to be able to use Java5 instrumentation to do
> the byte-code modification. I've also added the @Continuable annotation
> which marks classes and methods which should be byte-code enhanced.
>
> --
> Niklas Therning
> www.spamdrain.net
>
>
