java-concurrency

name	java-concurrency
description	Master Java concurrency - threads, executors, locks, CompletableFuture, virtual threads
sasmp_version	1.3.0
version	3.0.0
bonded_agent	02-java-advanced
bond_type	PRIMARY_BOND
allowed-tools	Read, Write, Bash, Glob, Grep
parameters	{"concurrency_model":{"type":"string","enum":["threads","executors","virtual_threads","reactive"]},"java_version":{"type":"string","default":"21"}}

Java Concurrency Skill

Master Java concurrency patterns for thread-safe applications.

Overview

This skill covers concurrency from basic threads to virtual threads (Java 21+), including thread pools, synchronization, and CompletableFuture.

When to Use This Skill

Use when you need to:

• Write thread-safe code
• Implement parallel processing
• Use async programming patterns
• Tune thread pools
• Debug concurrency issues

Topics Covered

Thread Management

• Thread lifecycle and states
• Daemon vs user threads
• Interrupt handling

Synchronization

• synchronized, volatile
• Lock interfaces (ReentrantLock)
• Atomic operations

Executors

• ThreadPoolExecutor configuration
• ForkJoinPool
• Virtual Threads (Java 21+)

CompletableFuture

• Async execution
• Chaining and composition
• Exception handling

Quick Reference

// Virtual Threads (Java 21+)
try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
    IntStream.range(0, 10_000).forEach(i ->
        executor.submit(() -> processRequest(i)));
}

// CompletableFuture composition
CompletableFuture<Result> result = fetchUser(id)
    .thenCompose(user -> fetchOrders(user.id()))
    .thenApply(orders -> processOrders(orders))
    .exceptionally(ex -> handleError(ex))
    .orTimeout(5, TimeUnit.SECONDS);

// Thread pool configuration
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    10, 50, 60L, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(1000),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

// Lock with timeout
ReentrantLock lock = new ReentrantLock();
if (lock.tryLock(1, TimeUnit.SECONDS)) {
    try {
        // critical section
    } finally {
        lock.unlock();
    }
}

Thread Pool Sizing

Workload	Formula	Example
CPU-bound	cores	8 threads
I/O-bound	cores * (1 + wait/compute)	80 threads

Troubleshooting

Problem	Cause	Solution
Deadlock	Circular lock	Lock ordering, tryLock
Race condition	Missing sync	Add locks/atomics
Thread starvation	Unfair scheduling	Fair locks

Debug Commands

jstack -l <pid> > threaddump.txt
jcmd <pid> Thread.print

Usage

Skill("java-concurrency")