Cách sử dụng remainingCapacity() trong PriorityBlockingQueue trên Android

Giới thiệu về PriorityBlockingQueue

PriorityBlockingQueue là một hàng đợi không giới hạn (unbounded) tuân theo thứ tự ưu tiên giống như PriorityQueue. Điểm mạnh là nó xử lý được lỗi OutOfMemoryError nhờ cơ chế mở rộng tự động.

Lưu ý quan trọng: Vì PriorityBlockingQueue là unbounded, phương thức remainingCapacity() luôn trả về Integer.MAX_VALUE (2.147.483.647). Đây là hành vi chuẩn của Java - các queue không giới hạn không có khái niệm "dung lượng còn lại" thực tế.

Ví dụ minh họa

Bước 1: Tạo project mới

Android Studio → File → New Project → điền thông tin.

Bước 2: Layout (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>

Bước 3: Code (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.PriorityBlockingQueue;

public class MainActivity extends AppCompatActivity {
    PriorityBlockingQueue<String> priorityBlockingQueue;

    @RequiresApi(api = Build.VERSION_CODES.LOLLIPOP)
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        priorityBlockingQueue = new PriorityBlockingQueue<>();
        final TextView actionEvent = findViewById(R.id.actionEvent);

        priorityBlockingQueue.add("sai");
        priorityBlockingQueue.add("ram");
        priorityBlockingQueue.add("krishna");
        priorityBlockingQueue.add("prasad");
        priorityBlockingQueue.add("ram");

        actionEvent.setText("" + priorityBlockingQueue);

        actionEvent.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                // Luôn trả về Integer.MAX_VALUE
                actionEvent.setText("" + priorityBlockingQueue.remainingCapacity());
            }
        });
    }
}

Kết quả chạy

Màn hình ban đầu: [prasad, ram, ram, sai, krishna] (sắp xếp theo thứ tự tự nhiên)

Click TextView hiển thị: 2147483647 (Integer.MAX_VALUE)

Phương thức thay thế hữu ích

Thay vì remainingCapacity(), bạn nên dùng:

• size() - số phần tử hiện tại
• isEmpty() - kiểm tra rỗng
• offer() - thêm phần tử (luôn thành công với unbounded queue)

Khi nào nên dùng PriorityBlockingQueue?

• Xử lý task theo độ ưu tiên
• Môi trường đa luồng cần thread-safe
• Không muốn lo về giới hạn dung lượng