System.in처럼 작동하는 InputStream을 만드는 방법

Question

System.in InputStream처럼 작동하지만 프로그래밍 방식으로 추가 할 수있는 InputStream 클래스를 만들려고합니다 (동적으로 추가 할 수있는 끝이없는 InputStream)

당신은 문제가 무슨 뜻인지 이해 한 경우

, 여기에 내가 쓴과

public class QueuedInputStream extends InputStream { 

     private LinkedList<Character> list; 

     public QueuedInputStream() { 
      list = new LinkedList<Character>(); 
     } 

     @Override 
     public int read() throws IOException { 
      while (list.isEmpty()) { 
       try { 
        Thread.sleep(1); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
      } 
      int value = (byte)list.get(0).charValue(); 
      list.remove(); 
      return value; 
     } 

     public void queue(String s) { 
      char[] chars = s.toCharArray(); 
      for(int i = 0; i < chars.length; i++) { 
       list.add(chars[i]); 
      } 
     } 

    } 

내가 바른 길에 있나요 시도이야? 아니면이 일을 완전히 잘못 했나요? 당신이 좀 더 설명하려면,

Answer 1

PipedInputStream 물어 주시기 바랍니다 :

A는 입력 스트림은, 파이프로 연결된 출력 스트림에 연결해야합니다 파이프; 파이프 된 입력 스트림은 파이프 된 출력 스트림에 에 기록 된 데이터 바이트를 제공합니다.

ByteArrayInputStream

:

가

이 InputStream 스트림으로부터 판독 될 수있다 바이트를 포함하는 내부 버퍼를 포함한다. 는 (당신은 건설 중에 배열을 제공하고, 스트림은 그것에서 읽습니다.)

Answer 2

귀하의 접근 방식은 타이밍 로직 주위에 약간의 우아함을 가지고 있지만. 심한 수면을 취할 필요가 없도록 스트림을 BlockingQueue으로 돌려 보내야합니다. 차단 대기열에서 take()으로 전화하면 입력이있을 때까지 통화가 차단됩니다.

하지만 아마도 이미 사용할 수있는 유틸리티가있을 것입니다. 하나의 옵션은 PipedInputStream과 PipedOutputStream을 사용한 다음 다른 OutputStream처럼 PipedOutputStream에 쓰는 것입니다. 다음은 완전한 예입니다.

public static void main(String[] args) throws IOException, InterruptedException { 
    PipedOutputStream pipedOutputStream = new PipedOutputStream(); 
    final PipedInputStream in = new PipedInputStream(pipedOutputStream); 

    PrintWriter writer = new PrintWriter(pipedOutputStream, true); 

    new Thread(new Runnable() { 
     @Override 
     public void run() { 
      BufferedReader reader = new BufferedReader(new InputStreamReader(in)); 
      try { 
       for (String line; (line = reader.readLine()) != null;) { 
        System.out.println(line); 
       } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    }).start(); 


    for (int i = 0; i < 1000; i++) { 
     writer.println(i); 
     Thread.sleep(1000); 
    } 
}