package com.nanoappli.test
 
// マルチスレッド処理サンプル
public class MultiThreadSample {
    public static void main( String args[] ) {
        TestClass inClass = ( new MultiThreadSample() ).getTestClass();
 
        /*------------------------*/
        /* 子スレッドの実行を行う */
        /*------------------------*/
        System.out.println( "test1" );
        Thread childThread = new Thread( inClass );
        childThread.start();
        System.out.println( "test2" );
 
 
        /*------------------------*/
        /* 親スレッドの仕事を行う */
        /*------------------------*/
        System.out.println( "main : start" );
        try {
            for ( int loop = 0; loop < 3; loop++ ) {
                System.out.println( "parent:" + String.valueOf( loop ) );
                java.lang.Thread.sleep( 1000 );
            }
        } catch ( InterruptedException ex ) {
            ex.printStackTrace();
        }
 
 
        /*----------------------------*/
        /* 子スレッドが終わるまで待つ */
        /*----------------------------*/
        try {
            synchronized ( childThread ) {
                childThread.wait();
            }
        } catch ( InterruptedException ex ) {
            ex.printStackTrace();
        }
 
        /* PG終了 */
        System.out.println( "main : end" );
    }
 
 
    //-------------------------------------------------------------------
    // インナークラスの取得メソッド
    //-------------------------------------------------------------------
    TestClass getTestClass() {
        return new TestClass();
    }
 
 
    //-------------------------------------------------------------------
    // 別スレッドで起動する内部クラス
    //-------------------------------------------------------------------
    class TestClass implements Runnable
    {
 
        // 子スレッド処理(Thread.start()からコールされる)
        public void run() {
            try {
                for ( int loop = 0; loop < 5; loop++ ) {
                    System.out.println( "child:" + String.valueOf( loop ) );
                    java.lang.Thread.sleep( 1000 );
                }
                System.out.println( "child:end" );
            } catch ( InterruptedException ex ) {
                ex.printStackTrace();
            }
 
            // 自分待ちになっているオブジェクトがいたら起こしてあげる
            synchronized ( this ) {
                this.notifyAll();
            }
        }
    }
}

package com.nanoappli.test;
 
import java.io.*;
import java.net.*;
import java.util.Arrays;
 
public class HelloWorld2
{
    public static void main( String args[] ) {
        int READ_BUFF_LEN = 2000;
        System.out.println( "start" );
        try {
            byte []readBuff = new byte[ READ_BUFF_LEN ];
            ServerSocket socket = new ServerSocket( 4949, 1, InetAddress.getByName( "192.168.1.1" ) );
 
            /*----------------------------------*/
            /* クライアントからの接続待ちに入る */
            /*----------------------------------*/
            while( true ) {
                Socket clientSocket;
                System.out.println( "接続待ち:" + socket.toString() );
                socket.setSoTimeout( 3000 );
                try {
                    System.out.print( "wait" );
                    clientSocket = socket.accept();
                } catch( SocketTimeoutException ex ) {
                    System.out.println( "-> 接続タイムアウトが発生しました. " );
                    continue;
                }
 
                System.out.println( "接続しました:" );
 
 
                /*----------------------------------*/
                /* データの受信を行う               */
                /*----------------------------------*/
                clientSocket.setSoTimeout( 2000 );
                InputStream inStream = clientSocket.getInputStream();
                int inputLen;
                int readPos = 0;
                while ( readPos < 10 ) {
                    System.out.print( "wait2" );
                    try {
                        inputLen = inStream.read( readBuff, readPos, READ_BUFF_LEN-readPos );
                    } catch( SocketTimeoutException ex ) {
                        System.out.println( "-> 受信タイムアウトが発生しました " );
                        continue;
                    }
                    System.out.println( "read:" + String.valueOf( inputLen ) );
                    readPos += inputLen;
                }
 
 
 
                /*--------------------------*/
                /* 受信したデータを表示する */
                /*--------------------------*/
                byte []readBuff2 = Arrays.copyOfRange( readBuff, 0, readPos );
                System.out.println( "データを受信しました:" + new String( readBuff2, "Windows-31J" ) );
 
 
                /*------------------------*/
                /* ソケットをクローズする */
                /*------------------------*/
                clientSocket.close();
 
            }
 
        } catch( Exception ex ) {
            ex.printStackTrace();
        }
        System.out.println( "end" );
    }
}

package com.nanoappli.test;
 
import java.io.*;
import java.net.*;
import java.util.Arrays;
 
public class HelloWorld
{
    public static void main( String args[] ) {
        int READ_BUFF_LEN = 2000;
        System.out.println( "start" );
        try {
            byte []readBuff = new byte[ READ_BUFF_LEN ];
            ServerSocket socket = new ServerSocket( 4949, 1, InetAddress.getByName( "192.168.1.1" ) );
 
 
            while( true ) {
                /*----------------------------------*/
                /* クライアントからの接続待ちに入る */
                /*----------------------------------*/
                System.out.println( "接続待ち:" + socket.toString() );
                Socket clientSocket = socket.accept();
                System.out.println( "接続しました:" );
 
 
                /*--------------------------------------------*/
                /* データの受信を行う(10byte受信するまで待つ) */
                /*--------------------------------------------*/
                InputStream inStream = clientSocket.getInputStream();
                int readPos = 0;
                while ( readPos < 10 ) {
                    int inputLen = inStream.read( readBuff, readPos, READ_BUFF_LEN-readPos );
                    readPos += inputLen;
                }
 
                /*----------------------------*/
                /* 受信したデータを表示する   */
                /* 文字コードははSJISとみなす */
                /*----------------------------*/
                byte []readBuff2 = Arrays.copyOfRange( readBuff, 0, readPos );
                System.out.println( "データを受信しました:" + new String( readBuff2, "Windows-31J" ) );
 
                /*------------------------*/
                /* ソケットをクローズする */
                /*------------------------*/
                clientSocket.close();
            }
 
        } catch( Exception ex ) {
            ex.printStackTrace();
        }
 
        System.out.println( "end" );
    }
}