Hướng Dẫn Sử Dụng Luồng Ảo trong Java

Java Virtual Threads, được giới thiệu trong JEP 425, là một phần của Project Loom và mang đến khả năng xử lý đồng thời nhẹ nhàng cho nền tảng Java. Mục tiêu của họ là làm cho lập trình đồng thời trở nên đơn giản và có thể mở rộng hơn.

Luồng Ảo Là Gì?

Luồng Ảo là một luồng nhẹ được quản lý bởi JVM, không phải bởi hệ điều hành. Khác với các luồng truyền thống, luồng ảo rất dễ dàng để tạo ra và cho phép số lượng lớn các luồng đồng thời mà không gặp phải các hạn chế tài nguyên thường thấy.

• Luồng Nền Tảng: Được quản lý bởi hệ điều hành, tốn kém về bộ nhớ và chuyển đổi ngữ cảnh.
• Luồng Ảo: Được quản lý bởi JVM, rẻ, có thể mở rộng lên đến hàng triệu luồng đồng thời.

Thread virtualThread = Thread.ofVirtual().start(() -> {
    System.out.println("Chạy trong một luồng ảo");
});

Cách Thức Hoạt Động

Luồng ảo dựa vào khả năng của JVM để tạm dừng và tiếp tục luồng một cách hiệu quả. Khi một luồng ảo thực hiện một thao tác chặn (như I/O), JVM có thể đỗ nó lại và tái sử dụng luồng mang cho các tác vụ khác.

Khái Niệm Chính:

• Luồng Mang: Luồng của hệ điều hành thực thi các luồng ảo.
• Park/Unpark: Cơ chế để tạm dừng và tiếp tục luồng mà không tiêu tốn tài nguyên của hệ điều hành.
• Tiếp Diễn: Tính năng nội bộ của JVM cho phép tiếp tục thực thi tại nơi mà luồng đã dừng lại.

Như vậy, các luồng ảo tách rời việc thực thi tác vụ khỏi sự sẵn có của các luồng hệ điều hành, cho phép khả năng đồng thời lớn mà không làm quá tải hệ thống.

Lợi Ích So Với Luồng Nền Tảng

Ví dụ: Việc tạo ra 1 triệu luồng nền tảng là điều gần như không thể; trong khi đó, luồng ảo có thể xử lý dễ dàng.

Các Vấn Đề Mà Luồng Ảo Giải Quyết

1. Giới Hạn Khả Năng Mở Rộng của các luồng nền tảng trong các ứng dụng đồng thời cao.
2. Độ Phức Tạp của mã bất đồng bộ/phản ứng: Giúp loại bỏ nhu cầu về các callback và các framework phản ứng trong nhiều trường hợp.
3. Kém Hiệu Quả Tài Nguyên: Các luồng nền tảng tiêu tốn bộ nhớ đáng kể; luồng ảo giúp giảm thiểu diện tích.

Có Thể Sử Dụng Luồng Ảo Thay Thế Lập Trình Phản Ứng Không?

Có, trong nhiều trường hợp:

• Luồng ảo làm cho I/O chặn rẻ, cho phép bạn viết mã mệnh lệnh mà không mất đi khả năng mở rộng.
• Lập trình phản ứng (ví dụ: Reactor, RxJava) chủ yếu là một giải pháp cho I/O không chặn. Luồng ảo cho phép hiệu suất tương tự với mã đồng bộ.
• Lưu ý: Đối với các hệ thống có thông lượng cực cao, lập trình phản ứng vẫn có thể cung cấp sự kiểm soát chi tiết hơn.

Các Cách Khác Nhau Để Tạo Ra Luồng Ảo

Sử Dụng API Thread

Thread vt = Thread.ofVirtual().start(() -> System.out.println("Luồng ảo đang chạy"));
vt.join();

Sử Dụng ExecutorService

ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();

executor.submit(() -> {
    System.out.println("Nhiệm vụ chạy trong luồng ảo");
});

executor.shutdown();

Tính Toán Cấu Trúc (Java 21+)

try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {
    scope.fork(() -> task1());
    scope.fork(() -> task2());
    scope.join(); // Chờ tất cả
}

Sử Dụng Luồng Ảo Với Spring Boot

Spring Boot có thể tận dụng luồng ảo trong các lớp controller hoặc service.

Thuộc Tính Spring Boot Cho Luồng Ảo

# application.yml
spring:
  task:
    execution:
      type: virtual
      pool:
        keep-alive: 60s      # Tùy chọn, thời gian giữ cho các luồng nhàn rỗi
        max-size: 1000       # Tùy chọn, số lượng luồng tối đa (thường chỉ là khuyến nghị cho các luồng ảo)

Hoặc trong application.properties:

spring.task.execution.type=virtual
spring.task.execution.pool.keep-alive=60s
spring.task.execution.pool.max-size=1000

Cách Hoạt Động

• spring.task.execution.type=virtual yêu cầu Spring sử dụng một executor luồng ảo thay vì ThreadPoolTaskExecutor mặc định.
• Bạn vẫn có thể cấu hình các thuộc tính pool, nhưng các luồng ảo rất nhẹ, vì vậy các giới hạn chủ yếu chỉ là khuyến nghị.
• Tất cả các nhiệm vụ @Async, nhiệm vụ theo lịch trình hoặc bất kỳ thành phần Spring nào sử dụng TaskExecutor sẽ tự động chạy trên luồng ảo.

Ví Dụ: Dịch Vụ Async Với Luồng Ảo Dựa Trên Thuộc Tính

Spring Boot cung cấp một thuộc tính để sử dụng luồng ảo cho TaskExecutor (được sử dụng bởi @Async, lập lịch, v.v.).

@Service
public class AsyncService {

    @Async
    public void processTask(String name) {
        System.out.println(Thread.currentThread() + " đang xử lý " + name);
        try {
            Thread.sleep(2000); // gọi chặn là ổn
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

Controller:

@RestController
@RequiredArgsConstructor
public class TestController {

    private final AsyncService service;

    @GetMapping("/run")
    public String run() {
        for (int i = 0; i < 10; i++) {
            service.processTask("task-" + i);
        }
        return "Nhiệm vụ đã được gửi";
    }
}

Bây giờ tất cả các nhiệm vụ sẽ chạy trên luồng ảo mà không cần cấu hình thủ công một executor.

Với @Async và Executor

@Configuration
public class VirtualThreadConfig {

    @Bean
    public Executor virtualThreadExecutor() {
        return Executors.newVirtualThreadPerTaskExecutor();
    }
}

Lợi Ích Trong Spring Boot

• Đơn giản hóa việc xử lý I/O chặn (ví dụ: JDBC, các cuộc gọi REST).
• Có thể mở rộng các điểm cuối xử lý hàng nghìn yêu cầu đồng thời.
• Giảm nhu cầu về các framework phản ứng như WebFlux nếu nút thắt chính của bạn là I/O.

Thực Hành Tốt Nhất

1. Sử dụng tính toán cấu trúc để quản lý vòng đời tốt hơn.
2. Sử dụng luồng ảo cho các tác vụ I/O; luồng nền tảng vẫn tốt cho các tác vụ nặng CPU.
3. Kết hợp với các tính năng bất đồng bộ của Spring Boot cho các ứng dụng web có thể mở rộng.

Tóm Lại

• Luồng ảo mang đến khả năng đồng thời nhẹ nhàng, có thể mở rộng cao.
• Chúng tách rời việc thực thi tác vụ khỏi các luồng OS, làm cho mã chặn trở nên rẻ.
• Chúng thường có thể thay thế lập trình phản ứng trong các ứng dụng nặng I/O.
• Tích hợp tốt với Spring Boot, cho phép các lập trình viên viết mã mệnh lệnh đơn giản mà vẫn có thể mở rộng.