KotlinのChannelでデータをやり取りする方法を完全ガイド！初心者にもわかる非同期通信の基本

先生と生徒の会話形式で理解しよう

生徒

「Kotlinのchannelって何ですか？どうやって使うんですか？」

先生

「channelは、Kotlinの非同期処理の一部で、複数の処理の間でデータをやり取りするための仕組みです。」

生徒

「なんだか難しそうですね… 実際に使ってみたいです！」

先生

「心配いりませんよ。channelの基本から丁寧に解説していきましょう。」

1. Kotlinのchannelとは？

Kotlinのchannelとは、複数の処理（スレッドやコルーチン）の間で「値を送ったり受け取ったりする」ための道具です。まるで郵便ポストのように、データを「入れる側」と「取り出す側」に分かれてやり取りを行います。

非同期処理（同時にいろんなことをする仕組み）では、処理同士がぶつからないように注意が必要ですが、channelを使うと、安全に値をやり取りできます。

2. channelを使った基本的なデータ送受信

それでは、実際にKotlinでchannelを使って、データを送ったり受け取ったりするサンプルコードを見てみましょう。


import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel

fun main() = runBlocking {
    val channel = Channel<Int>()

    // データを送る側（送信者）
    launch {
        for (i in 1..3) {
            println("送信: $i")
            channel.send(i)
        }
        channel.close()
    }

    // データを受け取る側（受信者）
    for (value in channel) {
        println("受信: $value")
    }
}

このコードでは、1から3までの数字をchannelを使ってやり取りしています。

3. 実行結果を見てみよう


送信: 1
受信: 1
送信: 2
受信: 2
送信: 3
受信: 3

このように、sendで送信されたデータが、for (value in channel)で順番に受信されています。

Kotlinを基礎からしっかり学びたい人や、 Java経験を活かしてモダンな言語にステップアップしたい人には、定番の入門書がこちらです。

基礎からわかるKotlinをAmazonで見る

※ Amazon広告リンク

4. channelの仕組みをイメージで理解しよう

channelは、例えるなら「荷物を運ぶベルトコンベア」のようなものです。送り手はベルトに荷物を乗せて、受け取り手はその荷物を順番に取っていきます。

このとき、受け取り手が処理しきれなければ、送り手は待たされますし、送り手が止まっていれば、受け取り手も待ちます。つまり、両者のタイミングがうまく調整される仕組みになっているのです。

5. channelの種類と特徴

実は、Kotlinのchannelにはいくつか種類があります。ここでは代表的な2つを紹介します。

Channel（デフォルト）：送信と受信がペアにならないと動かない。つまり、片方が待つ。
BufferedChannel（バッファ付き）：少しの間、データをためておける。処理のタイミングがずれてもOK。

初心者のうちは、まずはデフォルトのChannelを使って慣れていくのがオススメです。

6. バッファ付きchannelの使い方

今度は、バッファ付きchannel（Channelの中にいくつか値を貯めておけるタイプ）の例を見てみましょう。


import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel

fun main() = runBlocking {
    val channel = Channel<Int>(capacity = 2)

    launch {
        repeat(3) {
            println("送信: ${it + 1}")
            channel.send(it + 1)
        }
        channel.close()
    }

    launch {
        for (value in channel) {
            delay(500) // 少し時間をあけて受信
            println("受信: $value")
        }
    }
}

このコードでは、バッファが「2」なので、最初の2つの送信はすぐに通りますが、3つ目の送信は受信側が受け取るまで待たされます。