AndroidのConcurrentLinkedQueueでsize()を使用する方法を徹底解説

本記事では、Android開発におけるConcurrentLinkedQueueの基本的な使い方について、サンプルコードを交えながらわかりやすく解説します。

ConcurrentLinkedQueueとは

ConcurrentLinkedQueueは、リンクノードをベースとした無制限（アンバウンド）のキューです。最大の特徴は、複数のスレッドから安全に要素へアクセスできる点にあります。ロックフリーのアルゴリズムを採用しているため、マルチスレッド環境でも高いパフォーマンスを発揮します。

• 要素はFIFO（先入れ先出し）方式で管理される
• 新しい要素はキューの末尾（tail）から挿入される
• null値は許可されない

実装手順

ステップ1：新規プロジェクトの作成

Android Studioを起動し、「File」→「New Project」を選択して、必要事項を入力のうえ新しいプロジェクトを作成します。

ステップ2：レイアウトファイル（activity_main.xml）の作成

res/layout/activity_main.xml に以下のコードを記述します。

<?xml version = "1.0" encoding = "utf-8"?>
<LinearLayout xmlns:android = "https://schemas.android.com/apk/res/android"
   xmlns:app = "https://schemas.android.com/apk/res-auto"
   xmlns:tools = "https://schemas.android.com/tools"
   android:layout_width = "match_parent"
   android:gravity = "center"
   android:layout_height = "match_parent"
   tools:context = ".MainActivity"
   android:orientation = "vertical">
   <TextView
      android:id = "@+id/actionEvent"
      android:textSize = "40sp"
      android:layout_marginTop = "30dp"
      android:layout_width = "wrap_content"
      android:layout_height = "match_parent" />
</LinearLayout>

このレイアウトでは、ConcurrentLinkedQueueの内容を表示するためのTextViewを1つ配置しています。

ステップ3：MainActivity.javaの作成

src/MainActivity.java に以下のコードを記述します。

package com.example.myapplication;
import android.os.Build;
import android.os.Bundle;
import android.support.annotation.RequiresApi;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.TextView;
import java.util.concurrent.ConcurrentLinkedQueue;
public class MainActivity extends AppCompatActivity {
   ConcurrentLinkedQueue concurrentLinkedQueue;
   String head;
   @RequiresApi(api = Build.VERSION_CODES.LOLLIPOP)
   @Override
   protected void onCreate(Bundle savedInstanceState) {
      super.onCreate(savedInstanceState);
      setContentView(R.layout.activity_main);
      concurrentLinkedQueue = new ConcurrentLinkedQueue<String>();
      final TextView actionEvent = findViewById(R.id.actionEvent);
      concurrentLinkedQueue.add("sai");
      concurrentLinkedQueue.add("ram");
      concurrentLinkedQueue.add("krishna");
      concurrentLinkedQueue.add("prasad");
      concurrentLinkedQueue.add("ram");
      actionEvent.setText("" + concurrentLinkedQueue);
      actionEvent.setOnClickListener(new View.OnClickListener() {
         @Override
         public void onClick(View v) {
            actionEvent.setText("" +concurrentLinkedQueue.isEmpty());
         }
      });
   }
}

このコードでは、まずConcurrentLinkedQueueに5つの文字列要素を追加し、起動時にキューの全内容をTextViewへ表示しています。その後、TextViewをタップするとisEmpty()メソッドの判定結果が表示される仕組みです。

size()メソッドのポイント

size()メソッドを使えば、キュー内の現在の要素数を取得できます。ただし、ConcurrentLinkedQueueのsize()はキュー全体を走査してカウントするため、要素数が多い場合には処理コストが高くなる点に注意しましょう。単にキューが空かどうかを判定したいだけであれば、今回のサンプルのようにisEmpty()を使用する方が効率的です。

アプリの実行方法

それではアプリを実行してみましょう。ここでは、実際のAndroid端末をパソコンに接続しているものとします。Android Studioでプロジェクト内のアクティビティファイルを開き、ツールバーの「Run」アイコンをクリックしてください。実行デバイスとして自分のモバイル端末を選択すると、次のような初期画面が表示されます。

続いてTextViewをタップすると、以下のようにisEmpty()の判定結果が表示されます。