parthmistry

import reactor.core.publisher.Flux;

class ReactiveProcessData {

    private static ElapsedTimeMonitor elapsedTimeMonitor;

    public static void main(String[] args) throws Exception {

        int prefetchSize = 100;

parthmistry

import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxSink;

import java.sql.Connection;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

class PersonDataRetrieverForReactor implements Runnable {

parthmistry

import java.sql.Connection;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

parthmistry

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class SimplePrefetchMultiThreadedProcessData {

    public static void main(String[] args) throws Exception {

parthmistry

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;

public class BasicMultiThreadedProcessData {

    public static void main(String[] args) throws Exception {

parthmistry

public class SingleThreadedProcessData {

    public static void main(String[] args) throws Exception {
        try (var connection = PrefetchDemoUtil.getConnection()) {
            var elapsedTimeMonitor = new ElapsedTimeMonitor();

            var statement = connection.createStatement();
            statement.setFetchSize(100);

            var resultSet = statement.executeQuery("select * from persons");

parthmistry

var restClient = RestClient.builder(new HttpHost("SERVER_HOST", SERVER_PORT))
  .setHttpClientConfigCallback(clientConfigCallback -> {
    return clientConfigCallback.setMaxConnPerRoute(50).setMaxConnTotal(50);
  }).build();
var restClientTransport = new RestClientTransport(restClient, new JacksonJsonpMapper());
var elasticsearchClient = new ElasticsearchAsyncClient(restClientTransport);

parthmistry

var httpClient = HttpClients.custom()
  .setMaxConnPerRoute(15)
  .setMaxConnTotal(100)
  .build();

var httpAsyncClient = HttpAsyncClients.custom()
  .setMaxConnPerRoute(15)
  .setMaxConnTotal(100)
  .build();