Java8ストリームの後にクリーンアップ

Question

制限のないストリームから開始し、limit（）メソッドを使用してバインドを設定すると、制限に達するとStreamで使用されたリソースをどのようにクリーンアップできますか？例えば、私はFiles.linesメソッドが何をやろうとしているが、山車、文字列の代わりに、私は次のようになります機能を記述した場合：

public static Stream<Float> floats(File f) throws FileNotFoundException { 
     FileInputStream fis = new FileInputStream(f); 
     return Stream.generate(() -> { 

      byte[] buff = new byte[4]; 
      try { fis.read(buff); } 
      catch (Exception e) { e.printStackTrace(); } 
      return ByteBuffer.wrap(buff).getFloat(0); 

     }).limit(f.length()/4); 
    } 

これは、大規模なバイナリファイルをストリーミングする必要があります私がファイルの終わりに達するまでフロートがいっぱいです。フロートを構成する4バイトでファイルの長さをバイトで割ります。しかし、私はこの限界に達するとfis.close（）を実行する何らかの方法を見つけたいと思います。 Streams APIにはこれを行う方法がありますか？

Answer 1

私は別の可能性を思いついた。ハックのようなものだが、うまくいくようだ。私はストリームを常にtrueを返すフィルタで実行しますが、その過程でEOFがチェックされ、入力ストリームに達したら入力ストリームを閉じます。私はこれを行うためのよりクリーンな方法がAPIに組み込まれていることを期待していました。私は全く異なるアプローチで使用したい

Stream<Float> answer; 
    FileInputStream fis = new FileInputStream(f); 

    answer = Stream 
      .generate(() -> { 
       byte[] buff = new byte[4]; 
       try { fis.read(buff); } 
       catch (Exception e) { e.printStackTrace(); } 
       return ByteBuffer.wrap(buff).getFloat(0);}) 
      .filter(x -> { 
       try { if (fis.available() == 0) fis.close(); } 
       catch (Exception e) { e.printStackTrace(); } 
       return true;}) 
      .limit(f.length()/4); 

    return answer; 

Answer 2

：これで

public static Stream<Float> floats(File f) throws FileNotFoundException { 
    try(FileChannel fch = FileChannel.open(f.toPath(), StandardOpenOption.READ)) { 
     ByteBuffer bb = fch.map(FileChannel.MapMode.READ_ONLY, 0, fch.size()); 
     FloatBuffer fb = bb.asFloatBuffer(); 
     return IntStream.range(0, fb.remaining()).mapToObj(fb::get); 
    } 
    catch(IOException ex) { // or consider to declare "throws IOException" instead 
     FileNotFoundException fnfe = new FileNotFoundException(ex.getMessage()); 
     fnfe.initCause(ex); 
     throw fnfe; 
    } 
} 

のメソッドが返すとき、FileChannelはすでに閉鎖されています。また、潜在的により効率的です。操作の多くのために、元の値がfloat Sがある場合でも、DoubleStreamようにデータを処理する方が効率的かもしれないことに注意し、必要な場合にのみ、floatに戻し、最終結果の種類を絞り込む：

public static DoubleStream floatsAsDouble(File f) throws FileNotFoundException { 
    try(FileChannel fch = FileChannel.open(f.toPath(), StandardOpenOption.READ)) { 
     ByteBuffer bb = fch.map(FileChannel.MapMode.READ_ONLY, 0, fch.size()); 
     FloatBuffer fb = bb.asFloatBuffer(); 
     return IntStream.range(0, fb.remaining()).mapToDouble(fb::get); 
    } 
    catch(IOException ex) { // or consider to declare throwsIOException instead 
     FileNotFoundException fnfe = new FileNotFoundException(ex.getMessage()); 
     fnfe.initCause(ex); 
     throw fnfe; 
    } 
} 
… 
    float sum=(float)floatsAsDouble(new File("path")).sum(); 

Fileの代わりにPathを直接使用することもできます。