Skip to content

怎样正确构造动态的线程池? #45

@black-ei

Description

@black-ei

使用 KeyAffinityExecutor.newSerializingExecutor(IntSupplier parallelism, IntSupplier queueBufferSize,
String threadName) 返回的对象 没有设置并发参数方法

然后我尝试创建一个 KeyAffinityExecutorBuilder affinityExecutor = KeyAffinityExecutor.newKeyAffinityExecutor();
affinityExecutor.parallelism(this.mqttProperties::getConsumer)
.executor(KeyAffinityExecutorUtils.executor("mqtt-async-service-%d", () -> this.mqttProperties.getBlockingQueue()))
.usingRandom(it -> it > RANDOM_THRESHOLD)
.build();
可KeyAffinityExecutorUtils.executor方法是defalut 我无法使用 ,

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions