package com.csdhsm.concurrent;

import java.io.IOException;

import java.net.InetSocketAddress;

import java.net.ServerSocket;

import java.nio.ByteBuffer;

import java.nio.channels.AsynchronousCloseException;

import java.nio.channels.ClosedByInterruptException;

import java.nio.channels.SocketChannel;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

import java.util.concurrent.TimeUnit;

/**

* @Title: NIOInterruption.java

* @Package: com.csdhsm.concurrent

* @Description

* @author Han

* @date 2016-4-11 下午6:25:29

* @version V1.0

*/

class NIOBlocked implements Runnable{

private final SocketChannel sc;

public NIOBlocked(SocketChannel sc) {

this.sc = sc;

}

@Override

public void run() {

try {

System.out.println("Waiting for read() in " + this);

sc.read(ByteBuffer.allocate(1));

} catch (ClosedByInterruptException e){

System.out.println("ClosedByInterruptException");

} catch (AsynchronousCloseException e){

System.out.println("AsynchronousCloseException");

} catch (IOException e) {

throw new RuntimeException(e);

}

System.out.println("Exiting NIOBlocked.run() " + this);

}

}

public class NIOInterruption {

@SuppressWarnings("unused")

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

ExecutorService service = Executors.newCachedThreadPool();

ServerSocket socket = new ServerSocket(8080);

InetSocketAddress isa = new InetSocketAddress("localhost", 8080);

SocketChannel sc1 = SocketChannel.open(isa);

SocketChannel sc2 = SocketChannel.open(isa);

Future<?> f = service.submit(new NIOBlocked(sc1));

service.execute(new NIOBlocked(sc2));

service.shutdown();

TimeUnit.SECONDS.sleep(1);

f.cancel(true);

TimeUnit.SECONDS.sleep(1);

sc2.close();

}

}