com.google.common.util.concurrent.ExecutionList.executeListener()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(121)

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

ExecutionList.executeListener介绍

[英]Submits the given runnable to the given Executor catching and logging all RuntimeException thrown by the executor.
[中]将给定的runnable提交给给定的执行器捕获并记录执行器引发的所有RuntimeException。

代码示例

代码示例来源:origin: google/guava

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: google/j2objc

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

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

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: google/guava

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
 // NPE on null listener, so we propagate that contract up into the add method as well.
 checkNotNull(runnable, "Runnable was null.");
 checkNotNull(executor, "Executor was null.");
 // Lock while we check state. We must maintain the lock while adding the new pair so that
 // another thread can't run the list out from under us. We only add to the list if we have not
 // yet started execution.
 synchronized (this) {
  if (!executed) {
   runnables = new RunnableExecutorPair(runnable, executor, runnables);
   return;
  }
 }
 // Execute the runnable immediately. Because of scheduling this may end up getting called before
 // some of the previously added runnables, but we're OK with that. If we want to change the
 // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
 // it.
 executeListener(runnable, executor);
}

代码示例来源:origin: google/j2objc

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
 // NPE on null listener, so we propagate that contract up into the add method as well.
 checkNotNull(runnable, "Runnable was null.");
 checkNotNull(executor, "Executor was null.");
 // Lock while we check state. We must maintain the lock while adding the new pair so that
 // another thread can't run the list out from under us. We only add to the list if we have not
 // yet started execution.
 synchronized (this) {
  if (!executed) {
   runnables = new RunnableExecutorPair(runnable, executor, runnables);
   return;
  }
 }
 // Execute the runnable immediately. Because of scheduling this may end up getting called before
 // some of the previously added runnables, but we're OK with that. If we want to change the
 // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
 // it.
 executeListener(runnable, executor);
}

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

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
 // NPE on null listener, so we propagate that contract up into the add method as well.
 checkNotNull(runnable, "Runnable was null.");
 checkNotNull(executor, "Executor was null.");
 // Lock while we check state. We must maintain the lock while adding the new pair so that
 // another thread can't run the list out from under us. We only add to the list if we have not
 // yet started execution.
 synchronized (this) {
  if (!executed) {
   runnables = new RunnableExecutorPair(runnable, executor, runnables);
   return;
  }
 }
 // Execute the runnable immediately. Because of scheduling this may end up getting called before
 // some of the previously added runnables, but we're OK with that. If we want to change the
 // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
 // it.
 executeListener(runnable, executor);
}

代码示例来源:origin: com.diffplug.guava/guava-concurrent

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: com.google.guava/guava-jdk5

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-jruby

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: org.kill-bill.billing/killbill-platform-osgi-bundles-logger

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: org.kill-bill.billing/killbill-osgi-bundles-jruby

executeListener(reversedList.runnable, reversedList.executor);
reversedList = reversedList.next;

代码示例来源:origin: com.diffplug.guava/guava-concurrent

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
  // Fail fast on a null.  We throw NPE here because the contract of Executor states that it
  // throws NPE on null listener, so we propagate that contract up into the add method as well.
  checkNotNull(runnable, "Runnable was null.");
  checkNotNull(executor, "Executor was null.");
  // Lock while we check state.  We must maintain the lock while adding the new pair so that
  // another thread can't run the list out from under us. We only add to the list if we have not
  // yet started execution.
  synchronized (this) {
    if (!executed) {
      runnables = new RunnableExecutorPair(runnable, executor, runnables);
      return;
    }
  }
  // Execute the runnable immediately. Because of scheduling this may end up getting called before
  // some of the previously added runnables, but we're OK with that.  If we want to change the
  // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
  // it.
  executeListener(runnable, executor);
}

代码示例来源:origin: org.jboss.eap/wildfly-client-all

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
 // NPE on null listener, so we propagate that contract up into the add method as well.
 checkNotNull(runnable, "Runnable was null.");
 checkNotNull(executor, "Executor was null.");
 // Lock while we check state. We must maintain the lock while adding the new pair so that
 // another thread can't run the list out from under us. We only add to the list if we have not
 // yet started execution.
 synchronized (this) {
  if (!executed) {
   runnables = new RunnableExecutorPair(runnable, executor, runnables);
   return;
  }
 }
 // Execute the runnable immediately. Because of scheduling this may end up getting called before
 // some of the previously added runnables, but we're OK with that. If we want to change the
 // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
 // it.
 executeListener(runnable, executor);
}

代码示例来源:origin: org.kill-bill.billing/killbill-platform-osgi-bundles-logger

/**
 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
 * execute. If execution has already begun, the listener is executed immediately.
 *
 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
 * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
 * documentation.
 */
public void add(Runnable runnable, Executor executor) {
 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
 // NPE on null listener, so we propagate that contract up into the add method as well.
 checkNotNull(runnable, "Runnable was null.");
 checkNotNull(executor, "Executor was null.");
 // Lock while we check state. We must maintain the lock while adding the new pair so that
 // another thread can't run the list out from under us. We only add to the list if we have not
 // yet started execution.
 synchronized (this) {
  if (!executed) {
   runnables = new RunnableExecutorPair(runnable, executor, runnables);
   return;
  }
 }
 // Execute the runnable immediately. Because of scheduling this may end up getting called before
 // some of the previously added runnables, but we're OK with that. If we want to change the
 // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
 // it.
 executeListener(runnable, executor);
}

代码示例来源:origin: at.bestsolution.efxclipse.eclipse/com.google.guava

executeListener(runnable, executor);

代码示例来源:origin: Nextdoor/bender

executeListener(runnable, executor);

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-analytics

executeListener(runnable, executor);

代码示例来源:origin: com.google.guava/guava-jdk5

executeListener(runnable, executor);

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-jruby

executeListener(runnable, executor);

代码示例来源:origin: org.kill-bill.billing/killbill-osgi-bundles-jruby

executeListener(runnable, executor);

相关文章

微信公众号

最新文章

更多