?? stockhandler.java
字號:
/* * * Copyright (c) 1997-1999 Scott Oaks and Henry Wong. All Rights Reserved. * * Permission to use, copy, modify, and distribute this software * and its documentation for NON-COMMERCIAL purposes and * without fee is hereby granted. * * This sample source code is provided for example only, * on an unsupported, as-is basis. * * AUTHOR MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE SUITABILITY OF * THE SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED * TO THE IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A * PARTICULAR PURPOSE, OR NON-INFRINGEMENT. AUTHOR SHALL NOT BE LIABLE FOR * ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR * DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES. * * THIS SOFTWARE IS NOT DESIGNED OR INTENDED FOR USE OR RESALE AS ON-LINE * CONTROL EQUIPMENT IN HAZARDOUS ENVIRONMENTS REQUIRING FAIL-SAFE * PERFORMANCE, SUCH AS IN THE OPERATION OF NUCLEAR FACILITIES, AIRCRAFT * NAVIGATION OR COMMUNICATION SYSTEMS, AIR TRAFFIC CONTROL, DIRECT LIFE * SUPPORT MACHINES, OR WEAPONS SYSTEMS, IN WHICH THE FAILURE OF THE * SOFTWARE COULD LEAD DIRECTLY TO DEATH, PERSONAL INJURY, OR SEVERE * PHYSICAL OR ENVIRONMENTAL DAMAGE ("HIGH RISK ACTIVITIES"). AUTHOR * SPECIFICALLY DISCLAIMS ANY EXPRESS OR IMPLIED WARRANTY OF FITNESS FOR * HIGH RISK ACTIVITIES. */import java.util.*;import java.io.*;import java.net.*;class StockObservable extends Observable { String lastTick; void setTick(String s) { lastTick = s; setChanged(); notifyObservers(); }}public class StockHandler extends Thread { private BufferedReader br; private InputStream is; private Socket sock; private StockObservable stock; private boolean done = false; private Object lock = new Object(); class StockHandlerThread extends Thread { public void run() { String s; try { while ((s = br.readLine()) != null) stock.setTick(s); } catch (IOException ioe) {} done = true; synchronized(lock) { lock.notify(); } } } public StockHandler(StockObservable o, String host, int port) throws IOException, UnknownHostException { sock = new Socket(host, port); is = sock.getInputStream(); stock = o; } public void run() { br = new BufferedReader(new InputStreamReader(is)); Thread t = new StockHandlerThread(); t.start(); synchronized(lock) { while (!done) { try { lock.wait(Integer.MAX_VALUE); } catch (InterruptedException ie) { done = true; try { t.interrupt(); is.close(); sock.close(); } catch (IOException ioe) {} } } } }}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -