| | |
| | | if (argc < 4) { |
| | | assert("t_value.size()"); |
| | | } |
| | | // appPref.setIntData("gpu.index", 0); |
| | | // appPref.setIntData("RpcFEPort", 10021); |
| | | // appPref.setIntData("thread.max", 1);//线程池大小 |
| | | |
| | | appPref.setIntData("gpu.index", atoi(argv[1])); |
| | | appPref.setIntData("RpcFEPort", atoi(argv[2])); |
| | | appPref.setIntData("thread.max", atoi(argv[3]));//线程池大小 |
| | |
| | | IceRpcServer<FaceExtractServerI> server("faceExtractServer", appPref.getIntData("RpcFEPort"), "tcp"); |
| | | server.setMessageSizeMax(1024 * 1024 * 50); |
| | | server.setPoolInitSize(appPref.getIntData("thread.max")); |
| | | server.setPoolMaxSize(appPref.getIntData("thread.max")); |
| | | DBG("MaxPoolSize: " << std::max(appPref.getIntData("thread.max")*2, 32)); |
| | | server.setPoolMaxSize(std::max(appPref.getIntData("thread.max")*2, 32)); |
| | | server.runWaitShutDown(); |
| | | return 0; |
| | | } |