Java 类io.netty.util.concurrent.ImmediateExecutor 实例源码

public FutureListener(ResponseFuture f) {
  _future = f;
  LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
  queue.add(this);
  //_executor = new ThreadPoolExecutor(1, 1, 1, TimeUnit.HOURS, queue);
  _executor = ImmediateExecutor.INSTANCE;
  f.addListener(this, _executor);
}

public FutureListener(ResponseFuture f) {
  _future = f;
  LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
  queue.add(this);
  //_executor = new ThreadPoolExecutor(1, 1, 1, TimeUnit.HOURS, queue);
  _executor = ImmediateExecutor.INSTANCE;
  f.addListener(this, _executor);
}

public SslHandler(SSLEngine engine, boolean startTls) {
    this(engine, startTls, ImmediateExecutor.INSTANCE);
}

/**
 * Creates a new instance.
 *
 * @param engine    the {@link SSLEngine} this handler will use
 * @param startTls  {@code true} if the first write request shouldn't be
 *                  encrypted by the {@link SSLEngine}
 */
@SuppressWarnings("deprecation")
public SslHandler(SSLEngine engine, boolean startTls) {
    this(engine, startTls, ImmediateExecutor.INSTANCE);
}

/**
 * Creates a new instance.
 *
 * @param engine  the {@link SSLEngine} this handler will use
 */
public SslHandler(SSLEngine engine) {
    this(engine, ImmediateExecutor.INSTANCE);
}

/**
 * Creates a new instance.
 *
 * @param engine    the {@link SSLEngine} this handler will use
 * @param startTls  {@code true} if the first write request shouldn't be
 *                  encrypted by the {@link SSLEngine}
 */
public SslHandler(SSLEngine engine, boolean startTls) {
    this(engine, startTls, ImmediateExecutor.INSTANCE);
}

/**
 * Creates a new instance.
 *
 * @param engine  the {@link SSLEngine} this handler will use
 */
public SslHandler(SSLEngine engine) {
    this(engine, ImmediateExecutor.INSTANCE);
}

/**
 * Creates a new instance.
 *
 * @param engine    the {@link SSLEngine} this handler will use
 * @param startTls  {@code true} if the first write request shouldn't be
 *                  encrypted by the {@link SSLEngine}
 */
public SslHandler(SSLEngine engine, boolean startTls) {
    this(engine, startTls, ImmediateExecutor.INSTANCE);
}