package Threads;

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

/**
 * Created by Frank
 */
public class StopClose extends Thread {
  protected Socket io;

  public void run() {
    try {
      io = new Socket("java.sun.com", 80);
      BufferedReader is = new BufferedReader(new InputStreamReader(io.getInputStream()));
      System.out.println("StopClose reading");

      /**
       * 死鎖，因?yàn)樽x取響應(yīng)之前，HTTP責(zé)成客戶端發(fā)送一個(gè)請(qǐng)求（像GET/HTTP/1.0）和一個(gè)空行
       */
      String line = is.readLine();

      /**
       * 所以我們永遠(yuǎn)不可能到達(dá)這里
       */
      System.out.printf("StopClose FINISHED after reading %s!", line);

    } catch (IOException ex) {
      System.out.println("StopClose terminating:" + ex);
    }
  }

  public void shutDown() throws IOException {
    if (io != null) {
      synchronized (io) {
        io.close();
      }
    }
    System.out.println("StopClose.shutDown() complete");
  }

  public static void main(String[] args) throws InterruptedException, IOException {
    StopClose t = new StopClose();
    t.start();
    sleep(1000*5);
    t.shutDown();
  }
}