Cách sử dụng putLast() trong LinkedBlockingDeque trên Android

Giới thiệu về putLast()

putLast(E e) chèn phần tử vào cuối deque. Nếu deque đã đầy (chỉ khi bounded), phương thức sẽ block (chờ) cho đến khi có không gian hoặc bị ngắt (interrupted).

Khác với addLast() ném IllegalStateException khi đầy, hoặc offerLast() trả về false, putLast() phù hợp cho mô hình producer-consumer cần chờ đợi.

Ví dụ minh họa

Bước 1: Tạo project

Android Studio → File → New Project.

Bước 2: Layout

<?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.LinkedBlockingDeque;

public class MainActivity extends AppCompatActivity {
    LinkedBlockingDeque<String> linkedBlockingDeque;

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

        // Tạo deque CÓ GIỚI HẠN 5 phần tử để demo blocking
        linkedBlockingDeque = new LinkedBlockingDeque<>(5);
        final TextView actionEvent = findViewById(R.id.actionEvent);

        linkedBlockingDeque.add("sai");
        linkedBlockingDeque.add("ram");
        linkedBlockingDeque.add("krishna");
        linkedBlockingDeque.add("prasad");
        linkedBlockingDeque.add("ram"); // Đã đầy 5/5

        actionEvent.setText("" + linkedBlockingDeque);

        actionEvent.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    // Sẽ block vì deque đã đầy
                    // Cần thread khác gọi takeFirst() hoặc removeFirst() để giải phóng
                    linkedBlockingDeque.putLast("tutorialspoint.com");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                actionEvent.setText("" + linkedBlockingDeque);
            }
        });
    }
}

Lưu ý quan trọng về ví dụ này

Ví dụ trên sẽ bị TREO (block) vô hạn khi click vì deque đã đầy 5/5 và không có thread nào lấy phần tử ra. Để demo đúng cách, cần:

Phiên bản đúng - Demo Producer-Consumer

public class MainActivity extends AppCompatActivity {
    LinkedBlockingDeque<String> deque = new LinkedBlockingDeque<>(3);
    TextView textView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        textView = findViewById(R.id.actionEvent);
        textView.setText("Deque: " + deque);

        // Consumer thread - lấy phần tử sau 2 giây
        new Thread(() -> {
            try {
                Thread.sleep(2000);
                String removed = deque.takeFirst(); // Block cho đến khi có phần tử
                runOnUiThread(() -> textView.setText("Đã lấy: " + removed + "\nCòn: " + deque));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();

        // Producer - click để putLast
        textView.setOnClickListener(v -> {
            new Thread(() -> {
                try {
                    deque.putLast("Item-" + System.currentTimeMillis());
                    runOnUiThread(() -> textView.setText("Đã thêm\n" + deque));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        });
    }
}

So sánh các phương thức thêm vào cuối