インタフェース
java.util.function.Consumerの使用

Consumerを使用しているパッケージ

パッケージ	説明
java.lang	Javaプログラミング言語の設計にあたり基本的なクラスを提供します。
java.net.http	HTTPクライアントおよびWebSocket API
java.nio.channels	入出力操作を実行できるエンティティ(ファイル、ソケットなど)への接続を表すチャネルや、多重化された非ブロック入出力操作用のセレクタを定義します。
java.util	コレクション・フレームワーク、国際化サポート・クラス、サービス・ローダー、プロパティ、乱数生成、文字列解析とスキャン・クラス、Base64エンコーディングとデコード、ビット配列、およびその他のユーティリティ・クラスが含まれています。
java.util.concurrent	並行プログラミングでよく使用されるユーティリティ・クラスです。
java.util.function	関数型インタフェースは、ラムダ式やメソッド参照のターゲットとなる型を提供します。
java.util.stream	コレクションに対するマップ-リデュース変換など、要素のストリームに対する関数型の操作をサポートするクラスです。
jdk.jfr.consumer	このパッケージには、Flight Recorderデータを使用するためのクラスが含まれています。
jdk.jshell	Javaプログラミング言語コードの"snippets"をインタラクティブに評価するRead-Eval-Printループ(REPL)などのツールを作成するためのインタフェースを提供します。
jdk.jshell.execution	JShell実行エンジンを構築するための実装サポートを提供します。

java.langでのConsumerの使用

Consumer型のパラメータを持つjava.langのメソッド

修飾子と型	メソッド	説明
default void	Iterable.forEach(Consumer<? super T> action)	Iterableの各要素に対して指定されたアクションを、すべての要素が処理されるか、アクションが例外をスローするまで実行します。
void	StackWalker.forEach(Consumer<? super StackWalker.StackFrame> action)	現在のスレッドのStackFrameストリームの各要素に対して、このforEachメソッドを呼び出すメソッドである、スタックの先頭フレームを走査して、指定されたアクションを実行します。

java.net.httpでのConsumerの使用

型Consumerのパラメータを持つjava.net.httpのメソッド

修飾子と型	メソッド	説明
static HttpResponse.BodyHandler<Void>	HttpResponse.BodyHandlers.ofByteArrayConsumer(Consumer<Optional<byte[]>> consumer)	BodySubscribers.ofByteArrayConsumer(Consumer)から取得されたBodySubscriber<Void>を返すBodyHandler<Void>を返します。
static HttpResponse.BodySubscriber<Void>	HttpResponse.BodySubscribers.ofByteArrayConsumer(Consumer<Optional<byte[]>> consumer)	提供されたOptional<byte[]>のコンシューマに着信する本文データを提供するBodySubscriberを返します。

java.nio.channelsでのConsumerの使用

型Consumerのパラメータを持つjava.nio.channelsのメソッド

修飾子と型	メソッド	説明
int	Selector.select(Consumer<SelectionKey> action)	対応するチャネルがI/O操作の準備ができているキーに対して、アクションを選択および実行します。
int	Selector.select(Consumer<SelectionKey> action, long timeout)	対応するチャネルがI/O操作の準備ができているキーに対して、アクションを選択および実行します。
int	Selector.selectNow(Consumer<SelectionKey> action)	対応するチャネルがI/O操作の準備ができているキーに対して、アクションを選択および実行します。

java.utilでのConsumerの使用

Consumer型のパラメータを持つjava.utilのメソッド

修飾子と型	メソッド	説明
void	ArrayDeque.forEach(Consumer<? super E> action)
void	ArrayList.forEach(Consumer<? super E> action)
void	PriorityQueue.forEach(Consumer<? super E> action)
void	Vector.forEach(Consumer<? super E> action)
default void	Iterator.forEachRemaining(Consumer<? super E> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、残りの各要素に対して指定されたアクションを実行します。
default void	PrimitiveIterator.OfDouble.forEachRemaining(Consumer<? super Double> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、残りの各要素に対して指定されたアクションを実行します。
default void	PrimitiveIterator.OfInt.forEachRemaining(Consumer<? super Integer> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、残りの各要素に対して指定されたアクションを実行します。
default void	PrimitiveIterator.OfLong.forEachRemaining(Consumer<? super Long> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、残りの各要素に対して指定されたアクションを実行します。
default void	Spliterator.forEachRemaining(Consumer<? super T> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、現在のスレッド内で残りの各要素に対して指定されたアクションをシーケンシャルに実行します。
default void	Spliterator.OfDouble.forEachRemaining(Consumer<? super Double> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、現在のスレッド内で残りの各要素に対して指定されたアクションをシーケンシャルに実行します。
default void	Spliterator.OfInt.forEachRemaining(Consumer<? super Integer> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、現在のスレッド内で残りの各要素に対して指定されたアクションをシーケンシャルに実行します。
default void	Spliterator.OfLong.forEachRemaining(Consumer<? super Long> action)	すべての要素の処理が完了するかアクションから例外がスローされるまで、現在のスレッド内で残りの各要素に対して指定されたアクションをシーケンシャルに実行します。
void	Optional.ifPresent(Consumer<? super T> action)	値が存在する場合は、その値で指定されたアクションを実行し、そうでない場合は何もしません。
void	Optional.ifPresentOrElse(Consumer<? super T> action, Runnable emptyAction)	値が存在する場合は、指定されたアクションを値とともに実行し、そうでない場合は空のベースのアクションを実行します。
default boolean	Spliterator.OfDouble.tryAdvance(Consumer<? super Double> action)	残りの要素が存在する場合は、その要素に対して指定されたアクションを実行してtrueを返し、それ以外の場合はfalseを返します。
default boolean	Spliterator.OfInt.tryAdvance(Consumer<? super Integer> action)	残りの要素が存在する場合は、その要素に対して指定されたアクションを実行してtrueを返し、それ以外の場合はfalseを返します。
default boolean	Spliterator.OfLong.tryAdvance(Consumer<? super Long> action)	残りの要素が存在する場合は、その要素に対して指定されたアクションを実行してtrueを返し、それ以外の場合はfalseを返します。
boolean	Spliterator.tryAdvance(Consumer<? super T> action)	残りの要素が存在する場合は、その要素に対して指定されたアクションを実行してtrueを返し、それ以外の場合はfalseを返します。

java.util.concurrentでのConsumerの使用

Consumer型のパラメータを持つjava.util.concurrentのメソッド

修飾子と型	メソッド	説明
CompletableFuture<Void>	CompletableFuture.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionStage<Void>	CompletionStage.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)	このステージまたは指定された他のステージが正常に完了したときに、対応する結果を指定されたアクションへの引数に設定して実行される新しいCompletionStageを返します。
CompletableFuture<Void>	CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletableFuture<Void>	CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
CompletionStage<Void>	CompletionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)	このステージまたは指定された他のステージが正常に完了したときに、対応する結果を指定されたアクションへの引数に設定し、このステージのデフォルトの非同期実行機能を使用して実行される新しいCompletionStageを返します。
CompletionStage<Void>	CompletionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)	指定されたステージが正常に完了したときに、指定されたステージのいずれかが正常に完了したときに、指定されたエグゼキュータを使用して実行され、対応する結果が指定されたアクションの引数として返される新しいCompletionStageを返します。
CompletableFuture<Void>	SubmissionPublisher.consume(Consumer<? super T> consumer)	指定したコンシューマ関数を使用して、公開されたすべてのアイテムを処理します。
void	ArrayBlockingQueue.forEach(Consumer<? super E> action)
<U> void	ConcurrentHashMap.forEach(long parallelismThreshold, BiFunction<? super K,? super V,? extends U> transformer, Consumer<? super U> action)	各(キー, 値)のnullでない各変換に対し、指定されたアクションを実行します。
void	ConcurrentLinkedDeque.forEach(Consumer<? super E> action)
void	ConcurrentLinkedQueue.forEach(Consumer<? super E> action)
void	CopyOnWriteArrayList.forEach(Consumer<? super E> action)
void	CopyOnWriteArraySet.forEach(Consumer<? super E> action)
void	LinkedBlockingDeque.forEach(Consumer<? super E> action)
void	LinkedBlockingQueue.forEach(Consumer<? super E> action)
void	LinkedTransferQueue.forEach(Consumer<? super E> action)
void	PriorityBlockingQueue.forEach(Consumer<? super E> action)
void	ConcurrentHashMap.forEachEntry(long parallelismThreshold, Consumer<? super Map.Entry<K,V>> action)	各エントリに対して指定されたアクションを実行します。
<U> void	ConcurrentHashMap.forEachEntry(long parallelismThreshold, Function<Map.Entry<K,V>,? extends U> transformer, Consumer<? super U> action)	各エントリのnull以外の各変換に対して指定されたアクションを実行します。
void	ConcurrentHashMap.forEachKey(long parallelismThreshold, Consumer<? super K> action)	各キーに対して指定されたアクションを実行します。
<U> void	ConcurrentHashMap.forEachKey(long parallelismThreshold, Function<? super K,? extends U> transformer, Consumer<? super U> action)	各キーのnull以外の各変換に対して指定されたアクションを実行します。
void	ConcurrentHashMap.forEachValue(long parallelismThreshold, Consumer<? super V> action)	各値に対して指定されたアクションを実行します。
<U> void	ConcurrentHashMap.forEachValue(long parallelismThreshold, Function<? super V,? extends U> transformer, Consumer<? super U> action)	各値のnull以外の各変換に対して指定されたアクションを実行します。
CompletableFuture<Void>	CompletableFuture.thenAccept(Consumer<? super T> action)
CompletionStage<Void>	CompletionStage.thenAccept(Consumer<? super T> action)	このステージが正常に完了したときに、このステージの結果を指定されたアクションへの引数に設定して実行される新しいCompletionStageを返します。
CompletableFuture<Void>	CompletableFuture.thenAcceptAsync(Consumer<? super T> action)
CompletableFuture<Void>	CompletableFuture.thenAcceptAsync(Consumer<? super T> action, Executor executor)
CompletionStage<Void>	CompletionStage.thenAcceptAsync(Consumer<? super T> action)	このステージが正常に完了したときに、このステージの結果を指定されたアクションへの引数に設定し、このステージのデフォルトの非同期実行機能を使用して実行される新しいCompletionStageを返します。
CompletionStage<Void>	CompletionStage.thenAcceptAsync(Consumer<? super T> action, Executor executor)	このステージが正常に完了したときに、このステージの結果を指定されたアクションへの引数に設定し、指定されたエグゼキュータを使用して実行される新しいCompletionStageを返します。

java.util.functionでのConsumerの使用

Consumerを返すjava.util.functionのメソッド

修飾子と型	メソッド	説明
default Consumer<T>	Consumer.andThen(Consumer<? super T> after)	このオペレーションを実行した後、続けてafterオペレーションを実行する合成Consumerを返します。

Consumer型のパラメータを持つjava.util.functionのメソッド

修飾子と型	メソッド	説明
default Consumer<T>	Consumer.andThen(Consumer<? super T> after)	このオペレーションを実行した後、続けてafterオペレーションを実行する合成Consumerを返します。

java.util.streamでのConsumerの使用

java.util.streamでのConsumerのサブインタフェース

修飾子と型	インタフェース	説明
static interface	Stream.Builder<T>	Streamの可変ビルダーです。

Consumer型のパラメータを持つjava.util.streamのメソッド

修飾子と型	メソッド	説明
void	Stream.forEach(Consumer<? super T> action)	このストリームの各要素に対してアクションを実行します。
void	Stream.forEachOrdered(Consumer<? super T> action)	このストリームの各要素に対してアクションを実行します。その実行順は、ストリームの検出順が定義されている場合はその順番になります。
Stream<T>	Stream.peek(Consumer<? super T> action)	このストリームの要素から成るストリームを返すほか、その結果のストリームから消費される各要素に対し、指定されたアクションを実行します。

jdk.jfr.consumerでのConsumerの使用

型Consumerのパラメータを持つjdk.jfr.consumerのメソッド

修飾子と型	メソッド	説明
void	EventStream.onError(Consumer<Throwable> action)	例外が発生した場合に実行するアクションを登録します。
void	EventStream.onEvent(String eventName, Consumer<RecordedEvent> action)	名前と一致するすべてのイベントに対して実行するアクションを登録します。
void	EventStream.onEvent(Consumer<RecordedEvent> action)	ストリーム内のすべてのイベントで実行するアクションを登録します。

jdk.jshellでのConsumerの使用

型Consumerのパラメータを持つjdk.jshellのメソッド

修飾子と型	メソッド	説明
JShell.Subscription	JShell.onShutdown(Consumer<JShell> listener)	このJShellインスタンスが終了するときに呼び出されるコールバックを登録します。
JShell.Subscription	JShell.onSnippetEvent(Consumer<SnippetEvent> listener)	スニペットのステータスが変更されたときに呼び出されるコールバックを登録します。

jdk.jshell.executionでのConsumerの使用

型Consumerのパラメータを持つjdk.jshell.executionのメソッド

修飾子と型	メソッド	説明
static void	Util.detectJdiExitEvent(VirtualMachine vm, Consumer<String> unbiddenExitHandler)	VMDeathEventとVMDisconnectEventのJDIイベント・ストリームを監視します。

型Consumerの型引数を持つjdk.jshell.executionのメソッド・パラメータ

修飾子と型	メソッド	説明
static void	Util.forwardExecutionControlAndIO(ExecutionControl ec, InputStream inStream, OutputStream outStream, Map<String,Consumer<OutputStream>> outputStreamMap, Map<String,Consumer<InputStream>> inputStreamMap)	入力から指定されたExecutionControlインスタンスへコマンドを転送し、出力にレスポンスします。