Java框架中并发编程的未来发展趋势

import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;

AsynchronousSocketChannel channel = AsynchronousSocketChannel.open();
channel.connect(remoteAddress, null, new CompletionHandler<Void, AsynchronousSocketChannel>() {
  @Override
  public void completed(Void result, AsynchronousSocketChannel channel) {
    // 连接成功，继续执行
  }

  @Override
  public void failed(Throwable exc, AsynchronousSocketChannel channel) {
    // 连接失败，处理错误
  }
});

import java.util.stream.IntStream;

IntStream.range(0, 1000000).parallel()
  .forEach(i -> System.out.println(i));

import java.util.concurrent.locks.ReentrantReadWriteLock;

class ConcurrentCounter {
  private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
  private int count = 0;

  public void increment() {
    lock.writeLock().lock();
    try {
      count++;
    } finally {
      lock.writeLock().unlock();
    }
  }

  public int getCount() {
    lock.readLock().lock();
    try {
      return count;
    } finally {
      lock.readLock().unlock();
    }
  }
}

import reactor.core.publisher.Flux;

Flux.fromIterable(1, 2, 3, 4)
  .map(i -> i * 2)
  .subscribe(System.out::println);