redis-thread.cpp

#include <string>
#include <thread>
#include "RedisClient.h"

void f(int index){
    std::string strKey = "name";
    std::string strVal;
    CRedisClient* r = CRedisClient::Instance();
    int ret = r->Get(strKey, &strVal);
    std::cout << index << ":" << std::this_thread::get_id() << " request ret = " << ret << ", val = " << strVal << std::endl;
}

int main(int argc, char **argv) {
    CRedisClient* redisCli = CRedisClient::Instance();

    if (!redisCli->Initialize("127.0.0.1", 6379, 2, 30))
    {
        std::cout << "connect to redis failed" << std::endl;
        return -1;
    }

    std::vector<std::thread> tv;         //保存线程的情况
    for(int j = 1; j <= 20 ; ++j) {
        std::thread t(f, j);
        tv.push_back(std::move(t));
    }

    for(auto &thread : tv) {
        thread.join();
    }

    return 0;
}