io.netty.util.concurrent.DefaultEventExecutor#com.lambdaworks.redis.resource.DefaultClientResources源码实例Demo

public static ClientResources create() {
    final DefaultClientResources resources = new DefaultClientResources.Builder().eventLoopGroupProvider(
            new TestEventLoopGroupProvider()).build();

    Runtime.getRuntime().addShutdownHook(new Thread() {
        @Override
        public void run() {
            try {
                resources.shutdown(100, 100, TimeUnit.MILLISECONDS).get(10, TimeUnit.SECONDS);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    });

    return resources;
}
 

public static DefaultClientResources getClientResources()
{
    int threadPoolSize = Runtime.getRuntime().availableProcessors();
    threadPoolSize *= 2;

    DefaultClientResources resources = DefaultClientResources.builder()
            .ioThreadPoolSize(threadPoolSize)
            .computationThreadPoolSize(threadPoolSize)
            .build();
    Logging.writeLine("DefaultClientResources - ioThreads: %d, computeThreads: %d", resources.ioThreadPoolSize(), resources.computationThreadPoolSize());
    return resources;
}
 

@Before
public void before() throws Exception {

    clientResources = new DefaultClientResources.Builder()
            .commandLatencyPublisherOptions(DefaultEventPublisherOptions.create()).build();
    disqueClient = DisqueClient.create(clientResources, DisqueURI.create(TestSettings.host(), TestSettings.port()));
    disque = disqueClient.connect().sync();
}