线程池Demo(待续)

线程池Demo

 

见附件：

 

package thread;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class Test
{
    public static void main(String[] args) throws InterruptedException
    {
        try
        {
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String s;
            TestThreadPool manager = TestThreadPool.getInstance();
            manager.initThreadPool(1);

            int i = 0;

            long startTime = System.currentTimeMillis();
            while (i < 20)
            {

                double totalTime = (System.currentTimeMillis() - startTime) / 1000.0;
                System.out.println("totalTime:" + totalTime + "s");
                if (totalTime > 60)
                {
                    System.out.println("超时了哦~~");
                    break;
                }

                try
                {
                    manager.processQuery("bdk:" + Integer.toString(i));
                    i++;
                } catch (Exception e)
                {
                    Thread.sleep(1000);
                }

            }

            while ((s = br.readLine()) != null)
            {
                try
                {
                    manager.processQuery(s);
                } catch (Exception e)
                {
                    // e.printStackTrace();
                }
            }
        } catch (IOException e)
        {
        }
    }
}