Java优雅设计程序支持链式调用：多线程并发处理

要实现链式调用，可以使用方法链的方式设计程序。具体实现可以参考以下代码：

public class MongoQuery {
    private String collection;
    private Map<String, Object> criteria;
    private int pageSize;
    private int pageNo;
    private int poolSize;

    private MongoQuery() {
        this.criteria = new HashMap<>();
    }

    public static MongoQuery mongoQuery() {
        return new MongoQuery();
    }

    public MongoQuery eq(String key, Object value) {
        criteria.put(key, value);
        return this;
    }

    public MongoQuery pageSize(int size) {
        this.pageSize = size;
        return this;
    }

    public MongoQuery pageNo(int no) {
        this.pageNo = no;
        return this;
    }

    public MongoQuery pool(int size) {
        this.poolSize = size;
        return this;
    }

    public void then(Consumer<Result> callback) {
        // 异步处理逻辑，可使用线程池处理
        ExecutorService executorService = Executors.newFixedThreadPool(poolSize);
        Future<Result> future = executorService.submit(() -> {
            // 执行查询逻辑，返回结果
            // ...

            // 模拟查询结果
            Result result = new Result();
            result.setData(Collections.singletonList('查询结果'));
            return result;
        });

        // 处理查询结果
        try {
            Result result = future.get();
            callback.accept(result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            executorService.shutdown();
        }
    }

    public static class Result {
        private List<Object> data;

        public List<Object> getData() {
            return data;
        }

        public void setData(List<Object> data) {
            this.data = data;
        }
    }
}

使用示例：

MongoQuery.mongoQuery()
    .eq('name', '姓名')
    .pageSize(10)
    .pageNo(2)
    .pool(3)
    .then(result -> {
        List<Object> data = result.getData();
        // 处理查询结果
        // ...
    });

上述代码中，MongoQuery 类通过方法链的方式支持链式调用，并且通过 then() 方法实现了异步处理查询逻辑。在 then() 方法中，使用线程池执行查询逻辑，并通过回调函数 Consumer<Result> callback 处理查询结果。