Java 类org.apache.thrift7.server.TThreadPoolServer 实例源码

项目:jstorm-0.9.6.3-    文件:SaslTransportPlugin.java   
@Override
public TServer getServer(int port, TProcessor processor)
        throws IOException, TTransportException {
    TTransportFactory serverTransportFactory = getServerTransportFactory();

    // define THsHaServer args
    // original: THsHaServer + TNonblockingServerSocket
    // option: TThreadPoolServer + TServerSocket
    TServerSocket serverTransport = new TServerSocket(port);
    TThreadPoolServer.Args server_args = new TThreadPoolServer.Args(
            serverTransport).processor(new TUGIWrapProcessor(processor))
            .minWorkerThreads(64).maxWorkerThreads(64)
            .protocolFactory(new TBinaryProtocol.Factory());
    if (serverTransportFactory != null)
        server_args.transportFactory(serverTransportFactory);

    // construct THsHaServer
    return new TThreadPoolServer(server_args);
}
项目:learn_jstorm    文件:SaslTransportPlugin.java   
public TServer getServer(int port, TProcessor processor)
        throws IOException, TTransportException {
    TTransportFactory serverTransportFactory = getServerTransportFactory();

    // define THsHaServer args
    // original: THsHaServer + TNonblockingServerSocket
    // option: TThreadPoolServer + TServerSocket
    TServerSocket serverTransport = new TServerSocket(port);
    TThreadPoolServer.Args server_args = new TThreadPoolServer.Args(
            serverTransport).processor(new TUGIWrapProcessor(processor))
            .minWorkerThreads(64).maxWorkerThreads(64)
            .protocolFactory(new TBinaryProtocol.Factory());
    if (serverTransportFactory != null)
        server_args.transportFactory(serverTransportFactory);

    // construct THsHaServer
    return new TThreadPoolServer(server_args);
}
项目:Tstream    文件:SaslTransportPlugin.java   
public TServer getServer(int port, TProcessor processor)
        throws IOException, TTransportException {
    TTransportFactory serverTransportFactory = getServerTransportFactory();

    // define THsHaServer args
    // original: THsHaServer + TNonblockingServerSocket
    // option: TThreadPoolServer + TServerSocket
    TServerSocket serverTransport = new TServerSocket(port);
    TThreadPoolServer.Args server_args = new TThreadPoolServer.Args(
            serverTransport).processor(new TUGIWrapProcessor(processor))
            .minWorkerThreads(64).maxWorkerThreads(64)
            .protocolFactory(new TBinaryProtocol.Factory());
    if (serverTransportFactory != null)
        server_args.transportFactory(serverTransportFactory);

    // construct THsHaServer
    return new TThreadPoolServer(server_args);
}