threadpoolmain.java

彩信网关程序,SP程序,包含移动彩信代码和电信彩信代码!供学习之用

package com.hxyh.sanny.mms.cmcc.base.thread;


import java.io.PrintStream;

public class ThreadPoolMain
{

    public ThreadPoolMain()
    {
    }

    public static Runnable makeRunnable(final String name, final long firstDelay)
    {
        return new Runnable() {

            public void run()
            {
                try
                {
                    System.out.println(String.valueOf(String.valueOf(name)).concat(": starting up"));
                    Thread.sleep(2000L);
                    System.out.println(String.valueOf(String.valueOf(name)).concat(": doing some stuff"));
                    Thread.sleep(firstDelay);
                    System.out.println(String.valueOf(String.valueOf(name)).concat(": leaving"));
                }
                catch(InterruptedException ix)
                {
                    System.out.println(String.valueOf(String.valueOf(name)).concat(": got interrupted!"));
                    return;
                }
                catch(Exception x)
                {
                    x.printStackTrace();
                }
            }

            public String toString()
            {
                return name;
            }

        };
    }

    public static void main(String args[])
    {
        try
        {
            ThreadPool pool = new ThreadPool(20);
            pool.setTimeout(5000L);
           while (true)
           {
            Runnable ra = makeRunnable("RA", 1000L);
            pool.execute(ra);
            Runnable rb = makeRunnable("RB", 1000L);
            pool.execute(rb);
            Runnable rc = makeRunnable("RC", 2000L);
            pool.execute(rc);
            Runnable rd = makeRunnable("RD", 1000L);
            pool.execute(rd);
            Runnable re = makeRunnable("RE", 1000L);
            pool.execute(re);

            Thread.sleep(10000L);
           }

           /*
            pool.stopRequestIdleWorkers();
            Thread.sleep(2000L);
            pool.stopRequestIdleWorkers();
            Thread.sleep(5000L);
            pool.stopRequestAllWorkers();
           */
        }
        catch(InterruptedException ix)
        {
            ix.printStackTrace();
        }
    }
}