JavaのSystem.out.println（）;プログラムがブロックされてttyに待ち時間があります

Question

非常に遅いssh接続でプログラムを実行します。印刷速度が遅い場合、印刷速度が遅くなるかブロックされますか。

System.out.println(); 

だからコンソールに数ギガバイトしか印刷されないが、接続が遅い - 表示されないデータが表示される場所は？ ttyメモリのサイズは？私がしばらくの間接続を失う - それはまだ実行されますか？

Answer 1

はそれがttyの待ち時間

Javaのコンソール出力を持つことになりますプログラムをブロックしますので、潜在的にあなたのコードは、特にあなたが大量のデータを書き込む際に、ブロックすることがあり、blockingです。

ttyメモリのサイズは？

が、私はそれがあなたのカーネルに依存していることをかなり確信している、このold threadは、それが4096バイト、いくつかの時点であったことを示唆している：私は（カーネルのコードで見てきた

のlinux \ドライバ\文字\ serial.c）、SERIAL_XMIT_SIZEという#defineがあります。最初は私はそれを変更することができたかもしれないと思ったが、送信バッファは実際にメモリページ（4k）に固定されているようだ。私はしばらくの間の接続を失うことになる場合

 

- それはまだ動作しますか？

はい、誰もがttyに接続していない場合は、データを破棄できるため、はるかに高速に実行されます。

また、あなたのユースケースをシミュレートする小さなテストアプリケーションです。

Echo.java

import java.io.IOException; 

public class Echo { 
    public static void main(String[] args) throws InterruptedException, IOException { 
     final byte[] data = new byte[Test.BODY_LENGTH + Test.END_MARKER.length]; 
     int index = 0; 
     outer: while (true) { 
      data[index++] = (byte) System.in.read(); 
      final int dataOffset = index - Test.END_MARKER.length; 
      if (dataOffset < 0) { 
       continue; 
      } 
      for (int i = 0; i < Test.END_MARKER.length; i++) { 
       if (data[dataOffset + i] != Test.END_MARKER[i]) { 
        continue outer; 
       } 
      } 
      System.out.print(new String(data, 0, index)); 
      return; 
     } 
    } 
} 

Test.java

import java.io.File; 
import java.io.IOException; 
import java.util.concurrent.ThreadLocalRandom; 
import java.util.concurrent.TimeUnit; 

public class Test { 

    public static final byte[] END_MARKER = "$TERMINATE$".getBytes(); 
    public static final int BODY_LENGTH = 1024768; 

    public static void main(String[] args) throws IOException, InterruptedException { 
     StringBuilder data = new StringBuilder(); 
     for (int i = 0; i < BODY_LENGTH; i++) { 
      data.append((char) ('a' + ThreadLocalRandom.current().nextInt(('z' - 'a' + 1)))); 
     } 
     final Process process = new ProcessBuilder("java", Test.class.getPackage().getName() + ".Echo") 
       .directory(new File("out/production/week 3")) // Change to your output directory 
       .start(); 
     process.getOutputStream().write(data.toString().getBytes()); 
     process.getOutputStream().write(END_MARKER); 
     process.getOutputStream().flush(); 
     System.out.println("Written!"); 
     final boolean exitedAfterWroteData = process.waitFor(5, TimeUnit.SECONDS); 
     System.out.println(exitedAfterWroteData ? "Complete" : "Running"); // Will print running after 5 seconds 
     int read = 0; 
     while (process.getInputStream().read() > -1) { 
      read++; 
     } 
     if (read != data.toString().getBytes().length + END_MARKER.length) { 
      throw new IllegalStateException("Expected echo to print exactly " + BODY_LENGTH + END_MARKER.length + " symbols!"); 
     } 
     final boolean exitedAfterWeReadData = process.waitFor(50, TimeUnit.MILLISECONDS); 
     System.out.println(exitedAfterWeReadData ? "Complete" : "Running"); // Will print complete after a few milliseconds 
    } 
} 

Answer 2

いいえ、PrintWriterは完了の確認を待機しません。