View Javadoc

1   /***
2    * Redistribution  and use  in source  and binary  forms, with  or without
3    * modification, are permitted provided  that the following conditions are
4    * met :
5    *
6    * . Redistributions  of  source  code  must  retain  the  above copyright
7    *   notice, this list of conditions and the following disclaimer.
8    *
9    * . Redistributions in  binary form  must reproduce  the above  copyright
10   *   notice, this list of conditions  and the following disclaimer in  the
11   *   documentation and/or other materials provided with the distribution.
12   *
13   * . The name of the author may not be used to endorse or promote products
14   *   derived from this software without specific prior written permission.
15   *
16   * THIS SOFTWARE IS  PROVIDED BY THE  AUTHOR ``AS IS''  AND ANY EXPRESS  OR
17   * IMPLIED  WARRANTIES,  INCLUDING,  BUT   NOT  LIMITED  TO,  THE   IMPLIED
18   * WARRANTIES OF MERCHANTABILITY AND  FITNESS FOR A PARTICULAR  PURPOSE ARE
19   * DISCLAIMED.  IN NO  EVENT SHALL  THE AUTHOR  BE LIABLE  FOR ANY  DIRECT,
20   * INDIRECT,  INCIDENTAL,  SPECIAL,  EXEMPLARY,  OR  CONSEQUENTIAL  DAMAGES
21   * (INCLUDING,  BUT  NOT LIMITED  TO,  PROCUREMENT OF  SUBSTITUTE  GOODS OR
22   * SERVICES;  LOSS  OF USE,  DATA,  OR PROFITS;  OR  BUSINESS INTERRUPTION)
23   * HOWEVER CAUSED  AND ON  ANY THEORY  OF LIABILITY,  WHETHER IN  CONTRACT,
24   * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
25   * ANY  WAY  OUT OF  THE  USE OF  THIS  SOFTWARE, EVEN  IF  ADVISED OF  THE
26   * POSSIBILITY OF SUCH DAMAGE.
27   *
28   * $Id: AsynchronousAcceptor.java,v 1.4 2005/08/26 18:09:36 mat007 Exp $
29   */
30  
31  package jtge.engine.io;
32  
33  /***
34   * Wraps an acceptor to provide an asynchronous functionning.
35   * <p>
36   * This acceptor provides a non-blocking open and a blocking close.
37   *
38   * @author Mathieu Champlon
39   * @version $Revision: 1.4 $ $Date: 2005/08/26 18:09:36 $
40   */
41  public class AsynchronousAcceptor extends Thread implements IAcceptor
42  {
43      private final IAcceptor acceptor;
44  
45      /***
46       * Create an asynchronous acceptor.
47       *
48       * @param acceptor the acceptor to wrap
49       */
50      public AsynchronousAcceptor( final IAcceptor acceptor )
51      {
52          if( acceptor == null )
53              throw new IllegalArgumentException( "argument 'acceptor' is null" );
54          this.acceptor = acceptor;
55      }
56  
57      /***
58       * {@inheritDoc}
59       */
60      public final void run()
61      {
62          acceptor.open();
63      }
64  
65      /***
66       * {@inheritDoc}
67       */
68      public final void open()
69      {
70          start(); // FIXME change this to Runnable
71      }
72  
73      /***
74       * {@inheritDoc}
75       */
76      public final void close()
77      {
78          acceptor.close();
79          try
80          {
81              join();
82          }
83          catch( InterruptedException e )
84          {
85              return;
86          }
87      }
88  }