pluginagentmarketplace/custom-plugin-java6 files

Java Concurrency

Master Java concurrency - threads, executors, locks, CompletableFuture, virtual threads

Specification
Skill ID
pluginagentmarketplace/custom-plugin-java/java-concurrency
Publisher
pluginagentmarketplace
Repository
custom-plugin-java
Installs
0
Files
6
Synced
Sep 23, 2026
How to use it

Open any RiverX project, open the Skills panel in the chat, and search for this identifier. The files are fetched from the source repository at install time.

pluginagentmarketplace/custom-plugin-java/java-concurrencyInstalls these files
  • SKILL.md
  • assets/config.yaml
  • assets/schema.json
  • references/GUIDE.md
  • references/PATTERNS.md
  • scripts/validate.py

What this skill tells the agent

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

WorkloadFormulaExample
CPU-boundcores8 threads
I/O-boundcores * (1 + wait/compute)80 threads

Troubleshooting

ProblemCauseSolution
DeadlockCircular lockLock ordering, tryLock
Race conditionMissing syncAdd locks/atomics
Thread starvationUnfair schedulingFair locks

Debug Commands

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

Usage

Skill("java-concurrency")

Use this skill in a project

Open any RiverX project, search the Skills panel for pluginagentmarketplace/custom-plugin-java/java-concurrency, and install it in one click.

Use this skill