org.jclouds.concurrent.config.WithSubmissionTrace类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(5.9k)|赞(0)|评价(0)|浏览(123)

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

WithSubmissionTrace介绍

暂无

代码示例

代码示例来源:origin: jclouds/legacy-jclouds

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2. @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4. this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

代码示例来源:origin: io.cloudsoft.jclouds/jclouds-core

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2. @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4. this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源:origin: io.cloudsoft.jclouds/jclouds-core

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

代码示例来源:origin: org.jclouds/jclouds-core

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2. @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4. this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源:origin: org.jclouds/jclouds-core

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

代码示例来源:origin: com.amysta.jclouds/jclouds-core

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor) {
  2. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  3. }

代码示例来源:origin: com.amysta.jclouds/jclouds-core

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

代码示例来源:origin: apache/jclouds

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor) {
  2. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  3. }

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

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

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

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor) {
  2. this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  3. }

代码示例来源:origin: apache/jclouds

  1. /** returns the stack trace at the caller */
  2. private static StackTraceElement[] getStackTraceHere() {
  3. StackTraceElement[] trace = Thread.currentThread().getStackTrace();
  4. return filterTrace(trace);
  5. }

代码示例来源:origin: apache/jclouds

  1. protected ListeningExecutorService newExecutorService() {
  2. return WithSubmissionTrace.wrap(listeningDecorator(Executors.newSingleThreadExecutor()));
  3. }

代码示例来源:origin: io.cloudsoft.jclouds/jclouds-core

  1. private static ExecutionException addSubmissionTrace(StackTraceElement[] submissionTrace, ExecutionException e) {
  2. if (e.getCause() == null) {
  3. return filterTrace(e);
  4. }
  5. Throwable cause = e.getCause();
  6. StackTraceElement[] combined = filterTrace(concat(cause.getStackTrace(), submissionTrace, StackTraceElement.class));
  7. cause.setStackTrace(combined);
  8. return filterTrace(e);
  9. }

代码示例来源:origin: org.apache.jclouds.provider/profitbricks

  1. protected ListeningExecutorService newExecutorService() {
  2. return WithSubmissionTrace.wrap(listeningDecorator(Executors.newSingleThreadExecutor()));
  3. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. private static ExecutionException addSubmissionTrace(StackTraceElement[] submissionTrace, ExecutionException e) {
  2. if (e.getCause() == null) {
  3. return filterTrace(e);
  4. }
  5. Throwable cause = e.getCause();
  6. StackTraceElement[] combined = filterTrace(concat(cause.getStackTrace(), submissionTrace, StackTraceElement.class));
  7. cause.setStackTrace(combined);
  8. return filterTrace(e);
  9. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5. if (userExecutorFromConstructor != null)
  6. return userExecutorFromConstructor;
  7. return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

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

  1. private static ExecutionException addSubmissionTrace(StackTraceElement[] submissionTrace, ExecutionException e) {
  2. if (e.getCause() == null) {
  3. return filterTrace(e);
  4. }
  5. Throwable cause = e.getCause();
  6. StackTraceElement[] combined = filterTrace(concat(cause.getStackTrace(), submissionTrace, StackTraceElement.class));
  7. cause.setStackTrace(combined);
  8. return filterTrace(e);
  9. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_IO_WORKER_THREADS)
  4. ListeningExecutorService provideListeningIOExecutorService(@Named(PROPERTY_IO_WORKER_THREADS) int count,
  5. Closer closer) { // NO_UCD
  6. if (ioExecutorFromConstructor != null)
  7. return ioExecutorFromConstructor;
  8. return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("i/o thread %d", count)), closer);
  9. }

代码示例来源:origin: org.jclouds/jclouds-core

  1. private static ExecutionException addSubmissionTrace(StackTraceElement[] submissionTrace, ExecutionException e) {
  2. if (e.getCause() == null) {
  3. return filterTrace(e);
  4. }
  5. Throwable cause = e.getCause();
  6. StackTraceElement[] combined = filterTrace(concat(cause.getStackTrace(), submissionTrace, StackTraceElement.class));
  7. cause.setStackTrace(combined);
  8. return filterTrace(e);
  9. }

相关文章