生菜如何保证线程安全[暂停]

loading...


-3
@Test
public void testLettuce() throws InterruptedException {
    RedisClient redisClient = RedisClient.create("redis://zex1240888747@10.21.7.72:6379/0");
    StatefulRedisConnection<String, String> connection = redisClient.connect();
    RedisCommands<String, String> syncCommands = connection.sync();
    ThreadPoolExecutor t = (ThreadPoolExecutor)Executors.newFixedThreadPool(2);
    t.submit(()->{
       String key1result =  syncCommands.set("key1","111");
    });
    t.submit(()->{
        String key2result =  syncCommands.set("key2", "Hello, Redis!");
    });
    Thread.sleep(2000);
    connection.close();
    redisClient.shutdown();
}

看看我的代码,我启动两个线程发送redis命令与相同的连接,使用key1result和key2result接受结果 . 我们知道生菜可以通过一个tcp连接发送一次redis命令,但是如何恢复key1result和key2result对应的key1和key2返回值?

loading...

0回答

No Data

评论

暂时没有评论!