将算法的进程以多进程方式启动

chenshijun

2019-03-15 ed7186f89434ff9a19a5abdce8252d69460677ee

 QiaoJiaSystem/FaceDetectServer/main_detect.cpp

@@ -31,8 +31,8 @@
    int threadMax = atol(ich->getProperties()->getProperty("user.thread.max").c_str());
#endif
    ich->getProperties()->setProperty("Ice.ThreadPool.Server.SizeMax", std::to_string(threadMax));
    appPref.setLongData("gpu.index", atol(gpuIndex.c_str()));
    appPref.setLongData("thread.max", threadMax);
    appPref.setIntData("gpu.index", atol(gpuIndex.c_str()));
    appPref.setIntData("thread.max", threadMax);

    auto adapter = ich->createObjectAdapter(adapterName);
    adapter->add(new FaceDetectServerI(), Ice::stringToIdentity(identity));
@@ -47,13 +47,17 @@
    ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());
    auto ich = Ice::initialize(argc, argv);

    appPref.setLongData("gpu.index", 0);
    appPref.setLongData("thread.max", 32);
    if (argc < 4) {
        assert("t_value.size()");
    }
    appPref.setIntData("gpu.index", atoi(argv[1]));
    appPref.setIntData("RpcFDPort", atoi(argv[2]));
    appPref.setIntData("thread.max", atoi(argv[3]));//线程池大小

    IceRpcServer<FaceDetectServerI> server("faceServer", 10002, "tcp");
    IceRpcServer<FaceDetectServerI> server("faceServer", appPref.getIntData("RpcFDPort"), "tcp");
    server.setMessageSizeMax(1024 * 1024 * 50);
    server.setPoolInitSize(10);
    server.setPoolMaxSize(32);
    server.setPoolInitSize(appPref.getIntData("thread.max"));
    server.setPoolMaxSize(appPref.getIntData("thread.max"));
    server.runWaitShutDown();
    return 0;
}