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

ZLoop.start介绍

暂无

代码示例

代码示例来源：origin: org.projectreactor/reactor-net

@Override
public void run() {
  if (closed) {
    return;
  }
  if (null == zmq) {
    zmq = new ZContext(ioThreadCount);
    shutdownCtx = true;
  }
  socket = zmq.createSocket(socketType);
  socket.setIdentity(id.toString().getBytes());
  configure(socket);
  pollin = new ZMQ.PollItem(socket, ZMQ.Poller.POLLIN);
  if (log.isTraceEnabled()) {
    zloop.verbose(true);
  }
  zloop.addPoller(pollin, inputHandler, null);
  start(socket);
  zloop.start();
  zmq.destroySocket(socket);
}

代码示例来源：origin: io.projectreactor/reactor-net

@Override
public void run() {
  try {
    if (closed) {
      return;
    }
    if (null == zmq) {
      zmq = new ZContext(ioThreadCount);
      shutdownCtx = true;
    }
    socket = zmq.createSocket(socketType);
    socket.setIdentity(id.toString().getBytes());
    configure(socket);
    pollin = new ZMQ.PollItem(socket, ZMQ.Poller.POLLIN);
    if (log.isDebugEnabled()) {
      zloop.verbose(true);
    }
    zloop.addPoller(pollin, inputHandler, null);
    start(socket);
    zloop.start();
    zmq.destroySocket(socket);
  } catch (Exception e) {
    b.onError(e);
  }
}