package com.csdhsm.concurrent;

import java.io.InputStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

public class CloseResourse {

/**

* @Description the main mathod

* @author Han

* @param args

* @throws Exception

*/

public static void main(String[] args) throws Exception {

ExecutorService exec = Executors.newCachedThreadPool();

ServerSocket server = new ServerSocket(8080);

InputStream socketInput = new Socket("localhost",8080).getInputStream();

exec.execute(new IOBlocked(socketInput));

exec.execute(new IOBlocked(System.in));

TimeUnit.MILLISECONDS.sleep(100);

System.out.println("Shutting down all threads");

exec.shutdownNow();

TimeUnit.SECONDS.sleep(1);

System.out.println("Closing " + socketInput.getClass().getName());

socketInput.close();//Releases blocked thread

TimeUnit.SECONDS.sleep(1);

//Question

System.out.println("Closing" + System.in.getClass().getName());

System.in.close();//Releases blocked thread

server.close();

}

}