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

SSLEngine.getDelegatedTask介绍

[英]Returns a delegate task for this engine instance. Some engine operations may require the results of blocking or long running operations, and the SSLEngineResult instances returned by this engine may indicate that a delegated task result is needed. In this case the Runnable#run() method of the returned Runnabledelegated task must be called.
[中]返回此引擎实例的委托任务。某些引擎操作可能需要阻塞或长时间运行操作的结果，此引擎返回的SSLEngineResult实例可能表明需要委托的任务结果。在这种情况下，必须调用返回的Runnabledelegated任务的Runnable#run（）方法。

代码示例

代码示例来源：origin: apache/kafka

/**
 * returns delegatedTask for the SSLEngine.
 */
protected Runnable delegatedTask() {
  return sslEngine.getDelegatedTask();
}

代码示例来源：origin: redisson/redisson

@Override
public Runnable getDelegatedTask() {
  return engine.getDelegatedTask();
}

代码示例来源：origin: wildfly/wildfly

@Override
public Runnable getDelegatedTask() {
  return engine.getDelegatedTask();
}

代码示例来源：origin: wildfly/wildfly

@Override
public Runnable getDelegatedTask() {
  return delegate.getDelegatedTask();
}

代码示例来源：origin: wildfly/wildfly

@Override
public Runnable getDelegatedTask() {
  return delegate.getDelegatedTask();
}

代码示例来源：origin: wildfly/wildfly

public Runnable getDelegatedTask() {
  return delegate.getDelegatedTask();
}

代码示例来源：origin: io.netty/netty

@Override
public Runnable getDelegatedTask() {
  return engine.getDelegatedTask();
}

代码示例来源：origin: TooTallNate/Java-WebSocket

protected void consumeDelegatedTasks() {
  Runnable task;
  while ( ( task = sslEngine.getDelegatedTask() ) != null ) {
    tasks.add( exec.submit( task ) );
    // task.run();
  }
}

代码示例来源：origin: apache/geode

void handleBlockingTasks() {
 Runnable task;
 while ((task = engine.getDelegatedTask()) != null) {
  // these tasks could be run in other threads but the SSLEngine will block until they finish
  task.run();
 }
}

代码示例来源：origin: wildfly/wildfly

public Runnable getDelegatedTask() {
  return currentRef.get().getDelegatedTask();
}

代码示例来源：origin: wildfly/wildfly

public Runnable getDelegatedTask() {
  return currentRef.get().getDelegatedTask();
}

代码示例来源：origin: apache/nifi

private void performTasks() {
  Runnable runnable;
  while ((runnable = engine.getDelegatedTask()) != null) {
    runnable.run();
  }
}

代码示例来源：origin: wildfly/wildfly

public Runnable getDelegatedTask() {
  return currentRef.get().getDelegatedTask();
}

代码示例来源：origin: igniterealtime/Openfire

private SSLEngineResult.HandshakeStatus doTasks() {
  Runnable runnable;
  /*
    * We could run this in a separate thread, but do in the current for now.
    */
  while ((runnable = tlsEngine.getDelegatedTask()) != null) {
    runnable.run();
  }
  return tlsEngine.getHandshakeStatus();
}

代码示例来源：origin: igniterealtime/Openfire

private SSLEngineResult.HandshakeStatus doTasks() {
  Runnable runnable;
  /*
    * We could run this in a separate thread, but do in the current for now.
    */
  while ((runnable = tlsEngine.getDelegatedTask()) != null) {
    runnable.run();
  }
  return tlsEngine.getHandshakeStatus();
}

代码示例来源：origin: io.netty/netty

/**
 * Fetches all delegated tasks from the {@link SSLEngine} and runs them immediately.
 */
private void runDelegatedTasks() {
  for (;;) {
    final Runnable task;
    synchronized (handshakeLock) {
      task = engine.getDelegatedTask();
    }
    if (task == null) {
      break;
    }
    task.run();
  }
}

代码示例来源：origin: org.mongodb/mongo-java-driver

private void handleTask() throws NeedsTaskException {
  if (runTasks) {
    engine.getDelegatedTask().run();
  } else {
    throw new NeedsTaskException(engine.getDelegatedTask());
  }
}

代码示例来源：origin: rapidoid/rapidoid

private SSLEngineResult.HandshakeStatus executeTasks() {
  Runnable runnable;
  while ((runnable = engine.getDelegatedTask()) != null) {
    runnable.run();
  }
  SSLEngineResult.HandshakeStatus hsStatus = engine.getHandshakeStatus();
  U.must(hsStatus != SSLEngineResult.HandshakeStatus.NEED_TASK, "handshake shouldn't need additional tasks!");
  debug("after tasks: " + hsStatus);
  return hsStatus;
}

代码示例来源：origin: apache/ignite

/**
 * Runs all tasks needed to continue SSL work.
 *
 * @return Handshake status after running all tasks.
 */
private HandshakeStatus runTasks() {
  Runnable runnable;
  while ((runnable = sslEngine.getDelegatedTask()) != null) {
    if (log.isDebugEnabled())
      log.debug("Running SSL engine task: " + runnable + '.');
    runnable.run();
  }
  if (log.isDebugEnabled())
    log.debug("Finished running SSL engine tasks. HandshakeStatus: " + sslEngine.getHandshakeStatus());
  return sslEngine.getHandshakeStatus();
}

代码示例来源：origin: apache/ignite

/**
 * Runs all tasks needed to continue SSL work.
 *
 * @return Handshake status after running all tasks.
 */
private HandshakeStatus runTasks() {
  Runnable runnable;
  while ((runnable = sslEngine.getDelegatedTask()) != null) {
    if (log.isDebugEnabled())
      log.debug("Running SSL engine task [task=" + runnable + ", ses=" + ses + ']');
    runnable.run();
  }
  if (log.isDebugEnabled())
    log.debug("Finished running SSL engine tasks [handshakeStatus=" + sslEngine.getHandshakeStatus() +
      ", ses=" + ses + ']');
  return sslEngine.getHandshakeStatus();
}