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

ZContext.shadow介绍

[英]Creates new shadow context. Shares same underlying org.zeromq.Context instance but has own list of managed sockets, io thread count etc.
[中]创建新的阴影上下文。共享相同的基础组织。zeromq。上下文实例，但有自己的托管套接字列表、io线程计数等。

代码示例

代码示例来源：origin: miniway/zper

public ZPReaderWorker(ZContext context, String bindAddr, String identity)
{
  this.context = ZContext.shadow(context);
  this.bindAddr = bindAddr;
  this.identity = identity;
  logMgr = ZLogManager.instance();
}

代码示例来源：origin: miniway/zper

public ZPWriterWorker(ZContext context, String bindAddr, String identity, boolean decoder)
{
  this.context = ZContext.shadow(context);
  this.bindAddr = bindAddr;
  this.identity = identity;
  this.decoder = decoder;
  logMgr = ZLogManager.instance();
}

代码示例来源：origin: miniway/zper

public ZPReader(ZContext context, Properties conf)
{
  this.context = ZContext.shadow(context);
  sendBufferSize = Integer.parseInt(conf.getProperty("send_buffer", "1048576"));
  numWorkers = Integer.parseInt(conf.getProperty("reader.workers", "5"));
  bind = conf.getProperty("reader.bind", "tcp://*:5556");
  ZLogConfig zc = ZLogManager.instance().config();
  zc.set("base_dir", conf.getProperty("base_dir"));
  LOG.info("Data is stored at " + zc.get("base_dir"));
  workers = new ArrayList<byte[]>();
}

代码示例来源：origin: miniway/zper

public ZPWriter(ZContext context, Properties conf)
{
  this.context = ZContext.shadow(context);
  numWorkers = Integer.parseInt(conf.getProperty("writer.workers", "5"));
  bind = conf.getProperty("writer.bind", "tcp://*:5555");
  decoder = Boolean.parseBoolean(conf.getProperty("decoder", "true"));
  recvHWM = Integer.parseInt(conf.getProperty("receive_hwm", "1024"));
  recvBufferSize = Integer.parseInt(conf.getProperty("receive_buffer", "1048576"));
  maxMessageSize = Long.parseLong(conf.getProperty("max_message", "8388608")); // 8M
  ZLogConfig zc = ZLogManager.instance().config();
  zc.set("base_dir", conf.getProperty("base_dir"));
  zc.set("segment_size", Long.parseLong(conf.getProperty("segment_size", "536870912")));
  zc.set("flush_messages", Long.parseLong(conf.getProperty("flush_messages", "10000")));
  zc.set("flush_interval", Long.parseLong(conf.getProperty("flush_interval", "10000")));
  zc.set("retain_hours", Integer.parseInt(conf.getProperty("retain_hours", "168")));
  zc.set("recover", true);
  zc.set("allow_empty_message", Boolean.parseBoolean(conf.getProperty("allow_empty_message", "true")));
  LOG.info("Data is stored at " + zc.get("base_dir"));
  LOG.info("Using decoder " + decoder);
  workers = new ArrayList<byte[]>();
}

代码示例来源：origin: org.zeromq/jeromq

public static Socket fork(ZContext ctx, IAttachedRunnable runnable, Object... args)
  {
    Socket pipe = ctx.createSocket(ZMQ.PAIR);

    if (pipe != null) {
      pipe.bind(String.format("inproc://zctx-pipe-%d", pipe.hashCode()));
    }
    else {
      return null;
    }

    //  Connect child pipe to our pipe
    ZContext ccontext = ZContext.shadow(ctx);
    Socket cpipe = ccontext.createSocket(ZMQ.PAIR);
    if (cpipe == null) {
      return null;
    }
    cpipe.connect(String.format("inproc://zctx-pipe-%d", pipe.hashCode()));

    //  Prepare child thread
    Thread shim = new ShimThread(ccontext, runnable, args, cpipe);
    shim.start();

    return pipe;
  }
}