unbufferediotestservice.java

移动Agent编程工具Naplet

package serviceImpl;

import java.io.*;
import java.util.*;
import naplet.serviceChannel.*;

public class UnbufferedIOTestService
    extends naplet.resource.PrivilegedService
{

  /**
   * Like PipedReader, ServiceReader pipe provides two ways to read
   * characters: read() for a single character and read( buf, offset,
   * length ) for up to <code>length</code> characters of data.
   *
   * Similarly, ServiceWriter pipe privides two ways to write characters:
   * write(char c) for a single character and
   * write(char buf[], int offset, int length) for a number of characters.
   *
   */

  public void run()
  {
    for ( ; ; )
    {
      System.out.println( "Unbuffered I/O Test Service1>" );

      try
      {

        int j = 0;

        while ( inReader.read() != -1 )
        {
          j++;
        }

        System.out.println( "\nUnbufferedIOTestService reads " + j
                            + " characters from Naplet." );

        final int len = 10000000;

        int i = 0;
        for ( ; i < len; i++ )
        {
           outWriter.write( i );
        }

        System.out.println( "\nUnbufferedIOTestService writes "
                            + i + " characters to Naplet." );

        outWriter.close( );
        outStream.close( );
      }
      catch ( IOException ioe )
      {
        System.out.println( ioe.getMessage() );
      }
    }
  }
}