При каких условиях блок Java Scanner.hasNextLine()?

Question

документация Javadoc для Scanner.hasNextLine() состояний:

Возвращает истину, если есть еще одна линия на входе этого сканера. Этот метод май блок в ожидании ввода. Сканер не продвигается мимо каких-либо входных данных.

При каких условиях будет блокироваться метод?

Answer 1

Это зависит от источника, из которого сканер получает вход.

Например, если это файл, весь вход доступен, так hasNextLine() не будет блокировать (поскольку он может точно знать, когда конец файла достигнут, и там больше нет ввода.

На с другой стороны, если источник является стандартным входом, всегда может быть больше ввода - пользователь может всегда вводить больше ввода - поэтому hasNextLine() будет блокироваться до тех пор, пока пользователь не будет вводить новую строку ввода.

Answer 2

Предполагая, что «решить если он будет блокировать «, вы имеете в виду, что хотите знать, когда он будет работать.

Посмотрите, где вход назначен в методе hasNextLine

String result = findWithinHorizon(linePattern(), 0); 

Теперь посмотрим на findWithinHorizon метод

public String findWithinHorizon(Pattern pattern, int horizon) { 
    ensureOpen(); 
    if (pattern == null) 
     throw new NullPointerException(); 
    if (horizon < 0) 
     throw new IllegalArgumentException("horizon < 0"); 
    clearCaches(); 

    // Search for the pattern 
    while (true) { //it may block here if it never break 
     String token = findPatternInBuffer(pattern, horizon); 
     if (token != null) { 
      matchValid = true; 
      return token; 
     } 
     if (needInput) 
      readInput(); 
     else 
      break; // up to end of input 
    } 
    return null; 
} 

Как вы можете видеть, это будет цикл бесконечно до конца или до тех пор, пока ему не удастся его прочитать.

findPatternInBuffer - частный метод класса Scanner, который пытается прочитать ввод.

private String findPatternInBuffer(Pattern pattern, int horizon) { 
    matchValid = false; 
    matcher.usePattern(pattern); 
    int bufferLimit = buf.limit(); 
    int horizonLimit = -1; 
    int searchLimit = bufferLimit; 
    if (horizon > 0) { 
     horizonLimit = position + horizon; 
     if (horizonLimit < bufferLimit) 
      searchLimit = horizonLimit; 
    } 
    matcher.region(position, searchLimit); 
    if (matcher.find()) { 
     if (matcher.hitEnd() && (!sourceClosed)) { 
      // The match may be longer if didn't hit horizon or real end 
      if (searchLimit != horizonLimit) { 
       // Hit an artificial end; try to extend the match 
       needInput = true; 
       return null; 
      } 
      // The match could go away depending on what is next 
      if ((searchLimit == horizonLimit) && matcher.requireEnd()) { 
       // Rare case: we hit the end of input and it happens 
       // that it is at the horizon and the end of input is 
       // required for the match. 
       needInput = true; 
       return null; 
      } 
     } 
     // Did not hit end, or hit real end, or hit horizon 
     position = matcher.end(); 
     return matcher.group(); 
    } 

    if (sourceClosed) 
     return null; 

    // If there is no specified horizon, or if we have not searched 
    // to the specified horizon yet, get more input 
    if ((horizon == 0) || (searchLimit != horizonLimit)) 
     needInput = true; 
    return null; 
} 

Я отправил весь метод, чтобы дать вам лучшее представление о том, что я имел в виду «удастся прочитать».

Answer 3

Как решить, будет ли он блокироваться?

Чтобы решить, заблокирован ли hasNextLine, к сожалению, не поддерживается.

Это связано с тем, что базовые источники не всегда предоставляют API для поиска в потоке. Иными словами, реализация hasNextLine вызывает методы, которые сами могут блокировать, поэтому проблема является своего рода неотъемлемой.

---

Итак, что делать?

Если это действительно необходимый случай использования, я рекомендовал бы один из следующих подходов:

• Убедитесь, что условия являются правильными для hasNextLine. Предоставляйте сканеру только те источники, которые имеют определенный конец (например, файл или строку) и никогда не имеют «открытых» входных данных, таких как System.in.

  Если это часть API, вы можете обернуть сканер в своем классе, который предоставляет только «безопасные» конструкторы.

• Сверните свой собственный класс с нуля, который имеет тип метода willHasNextLineBlock. Это могло бы возможно быть реализовано несколько прочно используя InputStream.available.

---

В категории супер уродливые обходные пути мы находим:

• Создание попытку вызова hasNextLine в отдельном потоке и посмотреть, если он возвращается в течение разумного периода времени, а именно:

  boolean wouldBlock = false; 
  Thread t = new Thread(() -> s.hasNextLine()); 
  t.start(); 
  try { 
      t.join(100); 
  } catch (InterruptedException e) { 
      wouldBlock = true; 
  } 
  

• Использовать собственный входной поток (вещь как peekable stream, которую можно было бы использовать, прежде чем звонить hasNextLine. Что-то вроде этого

  CustomStream wrapped = new CustomStream(originalSource) 
  Scanner s = new Scanner(wrapped); 
  ... 
  if (wrapped.hasNextLine()) 
      // s.hasNextLine would not block 
  else 
      // s.hasNextLine would block 
  

  (Обратите внимание на то, что это несколько небезопасно, так как сканер может быть буферном некоторые данные из CustomStream.)