java-stream

1熱

1答えて

今、入力する文字列の数を入力するように要求するプログラムがあります。次に、IntStreamを使用して多数の文字列をリストに追加します。 final List<String> patterns = new ArrayList<>(); final int testCaseNumber = Integer.parseInt(scan.nextLine()); IntStream.range(

12熱

2答えて

は私が頻繁に私はこのようなことのための方法が記述されていることをこれを行うフォーム</p> <pre><code>t -> { // do something to t return t; } </code></pre> <p>を取る<code>Function</code>インタフェースのための機能

多くのラムダに消費者を変換します。 static <T> Function<T, T> consumeThenReturn(Consumer<T> consumer) { return t -> { consumer.accept(t); return t; }; } これは私はこのように、本当に素敵なことを行うことができます：私自身の方法に頼るこ

1熱

1答えて

executorThreadsPoolの代わりにjavaパラレルストリームを使用する方法は？

多くの並列呼び出しを実行するテストをAPIに書きたいと思います。 devicesList.parallelStream() .map(device -> do something) 私はjava8並列ストリームでそれを作成している可能性があり：を私は1つのデバイス上でそれを行うことができますどのように ExecutorService executor = Executors.n

6熱

5答えて

Java 8ストリームとvarargs

有効なJava 2nd Edによると、varargsを許可するメソッドシグネチャを書きたいが、コンパイル時に最低限の要素しか持たないようにするには、このようにメソッドシグネチャを記述する必要があります私は1のストリームを作成しています、特にので、は public void something(String required, String ... additional) { Stream

2熱

2答えて

Java8ストリームマップ - すべてのマップ操作が成功したかどうかを確認しますか？

ストリームを使用してリストを別のリストにマップしようとしています。元のリストの一部の要素がマップに失敗します。つまり、マッピング関数は適切な新しい値を見つけることができない可能性があります。いずれかのマッピングが失敗したかどうかを知りたい。理想的には、障害が発生したら処理を中止することもできます。私が現在やっていることは次のとおりです。私はそこストリームからNULL値を削除するには、noマ

2熱

2答えて

並行実行：未来対並行

私は、情報のためにリモートクライアントをポーリングし、その情報をリスト形式で返す呼び出し可能コードを書きました。私はthreadpoolexecutor forループを使い、Futureは複数のリモートクライアントに対して並列にタスクを実行しています。それから、私は将来のリストをすべてaddAll（）と組み合わせ、巨大な結合リストを扱います。私の質問は、parallelstream（）を将来のル

1熱

2答えて

複数のスレッド間でストリームインスタンスを共有することは安全ですか？

私は一連のキーを持っています。 class X { private static String[] keys = {"k1", "k2", ... }; リクエストからキーの値を抽出する必要があります。私はこのようないくつかの要求の処理方法でリスト必要なオブジェクトを値を抽出して作成するためにmapを使用することができると思う： public void processReq(Requ

0熱

2答えて

java 8ストリーム - 何も見つからない場合は処理します

何も見つからない場合、次のストリームパイプラインは機能しません。その場合、.findFirst()はNPEをスローします。どうすればこの問題を防ぐことができますか？ scheduleDurationContainers.stream() .filter(s -> s.getContainerType() == ScheduleIntervalContainerTypeEnum.BON

4熱

3答えて

だが、私はこのクラスを持っているとしましょう

のJavaストリーム（と条件付きストリーム操作）で複数のフィールドを追加します反復が行われたときに戻ります。しかし、私が望むのは、Javaストリームでこれを達成することです。以下は、私が持っているものである - それは動作しますが、私は1つのストリームにそれを凝縮させる方法がなければならないように感じる： public BigDecimal addFields(List<Thing> thin

1熱

2答えて

Javaのストリームでprintfを使用する

ラムダとストリームを初めて使用しています。私は削除された重複してソートされ、フォーマットされたArrayListを印刷しようとしています。私は次のように動作することを知っている：私はリストを持っているADFJKLXZまたは任意のランダムな文字の出力を生成します list.stream().distinct().forEach(System.out::print); 。しかし、私はのように見える