本文整理了Java中org.apache.xmlrpc.common.XmlRpcWorkerFactory类的一些代码示例，展示了XmlRpcWorkerFactory类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XmlRpcWorkerFactory类的具体详情如下：
包路径：org.apache.xmlrpc.common.XmlRpcWorkerFactory
类名称：XmlRpcWorkerFactory

XmlRpcWorkerFactory介绍

[英]A factory for XmlRpcWorker instances.
[中]XmlRpcWorker实例的工厂。

代码示例

代码示例来源：origin: rosjava/rosjava_core

/** Performs the given request.
   * @param pRequest The request being executed.
   * @return The result object.
   * @throws XmlRpcException The request failed.
   */
  public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
    final XmlRpcWorkerFactory factory = getWorkerFactory();
    final XmlRpcWorker worker = factory.getWorker();
    try {
      return worker.execute(pRequest);
    } finally {
      factory.releaseWorker(worker);
    }
  }
}

代码示例来源：origin: xmlrpc/xmlrpc-client

public XmlRpcController getController() {
  return factory.getController();
}

代码示例来源：origin: xmlrpc/xmlrpc-client

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @return The result object.
 * @throws XmlRpcException Performing the request failed.
 */
public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
  return getWorkerFactory().getWorker().execute(pRequest);
}

代码示例来源：origin: xmlrpc/xmlrpc-client

/** Performs a synchronous request.
 * @param pRequest The request being performed.
 * @return The requests result.
 * @throws XmlRpcException Performing the request failed.
 */
public Object execute(XmlRpcRequest pRequest)
    throws XmlRpcException {
  try {
    XmlRpcClient client = (XmlRpcClient) getController();
    return client.getTransportFactory().getTransport().sendRequest(pRequest);
  } finally {
    factory.releaseWorker(this);
  }
}

代码示例来源：origin: org.apache.xmlrpc/xmlrpc-common

/** Returns a worker for synchronous processing.
 * @return An instance of {@link XmlRpcWorker}, which is ready
 * for use.
 * @throws XmlRpcLoadException The clients maximum number of concurrent
 * threads is exceeded.
 */
public synchronized XmlRpcWorker getWorker() throws XmlRpcLoadException {
  int max = controller.getMaxThreads();
  if (max > 0  &&  numThreads == max) {
    throw new XmlRpcLoadException("Maximum number of concurrent requests exceeded: " + max);
  }
  if (max == 0) {
    return singleton;
  }
  ++numThreads;
  if (pool.size() == 0) {
    return newWorker();
  } else {
    return (XmlRpcWorker) pool.remove(pool.size() - 1);
  }
}

代码示例来源：origin: org.apache.xmlrpc/xmlrpc-client

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @param pCallback The callback being notified when the request is finished.
 * @throws XmlRpcException Performing the request failed.
 */
public void executeAsync(XmlRpcRequest pRequest,
             AsyncCallback pCallback) throws XmlRpcException {
  XmlRpcClientWorker w = (XmlRpcClientWorker) getWorkerFactory().getWorker();
  w.execute(pRequest, pCallback);
}

代码示例来源：origin: xmlrpc/xmlrpc-client

public void run(){
    Object result = null;
    Throwable th = null;
    try {
      XmlRpcClient client = (XmlRpcClient) getController();
      result = client.getTransportFactory().getTransport().sendRequest(pRequest);
    } catch (Throwable t) {
      th = t;
    }
    factory.releaseWorker(XmlRpcClientWorker.this);
    if (th == null) {
      pCallback.handleResult(pRequest, result);
    } else {
      pCallback.handleError(pRequest, th);
    }
  }
};

代码示例来源：origin: org.sonatype.sisu/sisu-xmlrpc-common

/** Returns a worker for synchronous processing.
 * @return An instance of {@link XmlRpcWorker}, which is ready
 * for use.
 * @throws XmlRpcLoadException The clients maximum number of concurrent
 * threads is exceeded.
 */
public synchronized XmlRpcWorker getWorker() throws XmlRpcLoadException {
  int max = controller.getMaxThreads();
  if (max > 0  &&  numThreads == max) {
    throw new XmlRpcLoadException("Maximum number of concurrent requests exceeded: " + max);
  }
  if (max == 0) {
    return singleton;
  }
  ++numThreads;
  if (pool.size() == 0) {
    return newWorker();
  } else {
    return (XmlRpcWorker) pool.remove(pool.size() - 1);
  }
}

代码示例来源：origin: org.apache.xmlrpc/xmlrpc-server

/** Performs the given request.
   * @param pRequest The request being executed.
   * @return The result object.
   * @throws XmlRpcException The request failed.
   */
  public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
    final XmlRpcWorkerFactory factory = getWorkerFactory();
    final XmlRpcWorker worker = factory.getWorker();
    try {
      return worker.execute(pRequest);
    } finally {
      factory.releaseWorker(worker);
    }
  }
}

代码示例来源：origin: rosjava/rosjava_core

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @param pCallback The callback being notified when the request is finished.
 * @throws XmlRpcException Performing the request failed.
 */
public void executeAsync(XmlRpcRequest pRequest,
             AsyncCallback pCallback) throws XmlRpcException {
  XmlRpcClientWorker w = (XmlRpcClientWorker) getWorkerFactory().getWorker();
  w.execute(pRequest, pCallback);
}

代码示例来源：origin: rosjava/rosjava_core

/** Returns a worker for synchronous processing.
 * @return An instance of {@link XmlRpcWorker}, which is ready
 * for use.
 * @throws XmlRpcLoadException The clients maximum number of concurrent
 * threads is exceeded.
 */
public synchronized XmlRpcWorker getWorker() throws XmlRpcLoadException {
  int max = controller.getMaxThreads();
  if (max > 0  &&  numThreads == max) {
    throw new XmlRpcLoadException("Maximum number of concurrent requests exceeded: " + max);
  }
  if (max == 0) {
    return singleton;
  }
  ++numThreads;
  if (pool.size() == 0) {
    return newWorker();
  } else {
    return (XmlRpcWorker) pool.remove(pool.size() - 1);
  }
}

代码示例来源：origin: org.sonatype.sisu/sisu-xmlrpc-server

/** Performs the given request.
   * @param pRequest The request being executed.
   * @return The result object.
   * @throws XmlRpcException The request failed.
   */
  public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
    final XmlRpcWorkerFactory factory = getWorkerFactory();
    final XmlRpcWorker worker = factory.getWorker();
    try {
      return worker.execute(pRequest);
    } finally {
      factory.releaseWorker(worker);
    }
  }
}

代码示例来源：origin: org.apache.xmlrpc/xmlrpc-client

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @return The result object.
 * @throws XmlRpcException Performing the request failed.
 */
public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
  return getWorkerFactory().getWorker().execute(pRequest);
}

代码示例来源：origin: org.sonatype.sisu/sisu-xmlrpc-client

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @return The result object.
 * @throws XmlRpcException Performing the request failed.
 */
public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
  return getWorkerFactory().getWorker().execute(pRequest);
}

代码示例来源：origin: xmlrpc/xmlrpc-client

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @param pCallback The callback being notified when the request is finished.
 * @throws XmlRpcException Performing the request failed.
 */
public void executeAsync(XmlRpcRequest pRequest,
             AsyncCallback pCallback) throws XmlRpcException {
  XmlRpcClientWorker w = (XmlRpcClientWorker) getWorkerFactory().getWorker();
  w.execute(pRequest, pCallback);
}

代码示例来源：origin: rosjava/rosjava_core

/** Performs a request with the clients default configuration.
 * @param pRequest The request being performed.
 * @return The result object.
 * @throws XmlRpcException Performing the request failed.
 */
public Object execute(XmlRpcRequest pRequest) throws XmlRpcException {
  return getWorkerFactory().getWorker().execute(pRequest);
}