Mercurial > hg > openjdk7.svn
view j2se/src/share/classes/com/sun/tools/example/trace/StreamRedirectThread.java @ 3:64ed597c0ad3 trunk
[svn] Load openjdk/jdk7/b15 into jdk/trunk.
author | xiomara |
---|---|
date | Thu, 05 Jul 2007 23:47:33 +0000 |
parents | 16f2b6c91171 |
children | bf1d8af0651f |
line wrap: on
line source
/* * Copyright 2001 Sun Microsystems, Inc. All Rights Reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Sun designates this * particular file as subject to the "Classpath" exception as provided * by Sun in the LICENSE file that accompanied this code. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara, * CA 95054 USA or visit www.sun.com if you need additional information or * have any questions. */ package com.sun.tools.example.trace; import java.io.*; /** * StreamRedirectThread is a thread which copies it's input to * it's output and terminates when it completes. * * @version @(#) StreamRedirectThread.java 1.12 07/05/05 00:46:58 * @author Robert Field */ class StreamRedirectThread extends Thread { private final Reader in; private final Writer out; private static final int BUFFER_SIZE = 2048; /** * Set up for copy. * @param name Name of the thread * @param in Stream to copy from * @param out Stream to copy to */ StreamRedirectThread(String name, InputStream in, OutputStream out) { super(name); this.in = new InputStreamReader(in); this.out = new OutputStreamWriter(out); setPriority(Thread.MAX_PRIORITY-1); } /** * Copy. */ public void run() { try { char[] cbuf = new char[BUFFER_SIZE]; int count; while ((count = in.read(cbuf, 0, BUFFER_SIZE)) >= 0) { out.write(cbuf, 0, count); } out.flush(); } catch(IOException exc) { System.err.println("Child I/O Transfer - " + exc); } } }