org.jboss.threads.JBossThreadFactory类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(105)

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

JBossThreadFactory介绍

[英]A factory for JBossThread instances.
[中]JBossThread实例的工厂。

代码示例

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

@Override
public ExecutorService get() {
  ThreadGroup threadGroup = new ThreadGroup("KeyAffinityService ThreadGroup");
  String namePattern = "KeyAffinityService Thread Pool -- %t";
  PrivilegedAction<ThreadFactory> action = () -> new JBossThreadFactory(threadGroup, Boolean.FALSE, null, namePattern, null, null);
  return Executors.newCachedThreadPool(doPrivileged(action));
}

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

public Thread newThread(final Runnable target) {
  final AccessControlContext context;
  if ((context = creatingContext) != null) {
    return AccessController.doPrivileged(new ThreadCreateAction(target), context);
  } else {
    return createThread(target);
  }
}

代码示例来源:origin: org.jboss.as/jboss-as-testsuite-shared

static ExecutorService createDefaultExecutor() {
  final ThreadGroup group = new ThreadGroup("mgmt-client-thread");
  final ThreadFactory threadFactory = new JBossThreadFactory(group, Boolean.FALSE, null, "%G " + executorCount.incrementAndGet() + "-%t", null, null, AccessController.getContext());
  return new ThreadPoolExecutor(4, 4, 30L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(256), threadFactory);
}

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

public JBossThreadFactory run() {
    return new JBossThreadFactory(threadGroup, Boolean.FALSE, null, namePattern, null, null);
  }
});

代码示例来源:origin: org.jboss.as/jboss-as-server

@Override
public void start(StartContext context) throws StartException {
  try {
    final JBossThreadFactory threadFactory = new JBossThreadFactory(new ThreadGroup("ServerDeploymentRepository-temp-threads"), Boolean.FALSE, null, "%G - %t", null, null, AccessController.getContext());
    tempFileProvider = TempFileProvider.create("temp", Executors.newScheduledThreadPool(2, threadFactory));
  } catch (IOException e) {
    throw ServerMessages.MESSAGES.failedCreatingTempProvider();
  }
  ServerLogger.ROOT_LOGGER.debugf("%s started", DeploymentMountProvider.class.getSimpleName());
}

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

@Override
  public ThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup(InfinispanBeanManager.class.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

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

@Override
public void start(final StartContext context) throws StartException {
  final ThreadGroup threadGroup = new ThreadGroup("Weld ThreadGroup");
  final ThreadFactory factory = new JBossThreadFactory(threadGroup, Boolean.FALSE, null, THREAD_NAME_PATTERN, null, null);
  // set TCCL to null for new threads to make sure no deployment classloader leaks through this executor's TCCL
  // Weld does not mind having null TCCL in this executor
  this.executor = Executors.newFixedThreadPool(bound, runnable -> {
    Thread thread = factory.newThread(runnable);
    if (WildFlySecurityManager.isChecking()) {
      AccessController.doPrivileged(new PrivilegedAction<Void>() {
        public Void run() {
          thread.setContextClassLoader(null);
          return null;
        }
      });
    } else {
      thread.setContextClassLoader(null);
    }
    return thread;
  }
  );
  if (executorServicesConsumer != null) executorServicesConsumer.accept(this);
}

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

public Thread newThread(final Runnable target) {
  final AccessControlContext context;
  if ((context = creatingContext) != null) {
    return AccessController.doPrivileged(new ThreadCreateAction(target), context);
  } else {
    return createThread(target);
  }
}

代码示例来源:origin: org.jboss.as/jboss-as-host-controller

@Override
public void start(StartContext context) throws StartException {
  final ExecutorService executorService = getExecutorServiceInjector().getValue();
  this.hostControllerConfigurationPersister = new HostControllerConfigurationPersister(environment, hostControllerInfo, executorService, extensionRegistry);
  setConfigurationPersister(hostControllerConfigurationPersister);
  prepareStepHandler.setExecutorService(executorService);
  ThreadFactory threadFactory = new JBossThreadFactory(new ThreadGroup("proxy-threads"), Boolean.FALSE, null, "%G - %t", null, null, AccessController.getContext());
  proxyExecutor = Executors.newCachedThreadPool(threadFactory);
  ThreadFactory pingerThreadFactory = new JBossThreadFactory(new ThreadGroup("proxy-pinger-threads"), Boolean.TRUE, null, "%G - %t", null, null, AccessController.getContext());
  pingScheduler = Executors.newScheduledThreadPool(PINGER_POOL_SIZE, pingerThreadFactory);
  super.start(context);
}

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

public JBossThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup("JdrReportCollector-threads"), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

代码示例来源:origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ExecutorService get() {
  ThreadGroup threadGroup = new ThreadGroup("KeyAffinityService ThreadGroup");
  String namePattern = "KeyAffinityService Thread Pool -- %t";
  PrivilegedAction<ThreadFactory> action = () -> new JBossThreadFactory(threadGroup, Boolean.FALSE, null, namePattern, null, null);
  return Executors.newCachedThreadPool(doPrivileged(action));
}

代码示例来源:origin: org.jboss.threads/jboss-threads

public Thread newThread(final Runnable target) {
  final AccessControlContext context;
  if ((context = creatingContext) != null) {
    return AccessController.doPrivileged(new ThreadCreateAction(target), context);
  } else {
    return createThread(target);
  }
}

代码示例来源:origin: org.jboss.as/jboss-as-server

final ThreadFactory threadFactory = new JBossThreadFactory(threadGroup, Boolean.FALSE, null, namePattern, null, null, AccessController.getContext());

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

public JBossThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup("NamingEventCoordinator-threads"), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

代码示例来源:origin: org.wildfly/wildfly-controller-client

static ExecutorService createDefaultExecutor() {
  final ThreadGroup group = new ThreadGroup("management-client-thread");
  final ThreadFactory threadFactory = new JBossThreadFactory(group, Boolean.FALSE, null, "%G " + executorCount.incrementAndGet() + "-%t", null, null, doPrivileged(new PrivilegedAction<AccessControlContext>() {
    public AccessControlContext run() {
      return AccessController.getContext();
    }
  }));
  return new ThreadPoolExecutor(2, DEFAULT_MAX_THREADS, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), threadFactory);
}

代码示例来源:origin: org.jboss.as/jboss-as-controller

/** {@inheritDoc} */
@Override
public synchronized void start(StartContext context) throws StartException {
  SERVER_MANAGEMENT_LOGGER.debugf("Starting operation handler service %s", context.getController().getName());
  if(executor.getOptionalValue() == null) {
    // Create the default executor
    final BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(WORK_QUEUE_SIZE);
    final ThreadFactory threadFactory = new JBossThreadFactory(new ThreadGroup(getThreadGroupName()), Boolean.FALSE, null, "%G - %t", null, null, AccessController.getContext());
    final ThreadPoolExecutor executorService = new ThreadPoolExecutor(POOL_CORE_SIZE, POOL_MAX_SIZE,
                            60L, TimeUnit.SECONDS, workQueue,
                            threadFactory);
    // Allow the core threads to time out as well
    executorService.allowCoreThreadTimeOut(true);
    getExecutorInjector().inject(executorService);
  }
}

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

@Override
  public JBossThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup(SimpleCache.class.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

代码示例来源:origin: org.wildfly/wildfly-controller

public ModelControllerClientOperationHandler(final ModelController controller,
                       final ManagementChannelAssociation channelAssociation, final Subject subject) {
  this.controller = controller;
  this.channelAssociation = channelAssociation;
  this.subject = subject;
  // Create the client request executor
  final BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(WORK_QUEUE_SIZE);
  final ThreadFactory threadFactory = new JBossThreadFactory(new ThreadGroup("management-handler-thread"), Boolean.FALSE, null, "%G - %t", null, null, doPrivileged(GetAccessControlContextAction.getInstance()));
  ThreadPoolExecutor executor = new ThreadPoolExecutor(POOL_CORE_SIZE, POOL_MAX_SIZE,
      60L, TimeUnit.SECONDS, workQueue,
      threadFactory);
  // Allow the core threads to time out as well
  executor.allowCoreThreadTimeOut(true);
  clientRequestExecutor = executor;
}

代码示例来源:origin: org.jboss.as/jboss-as-process-controller

configuration.setBindAddress(pcInetSocketAddress);
configuration.setSocketFactory(ServerSocketFactory.getDefault());
final ThreadFactory threadFactory = new JBossThreadFactory(new ThreadGroup("ProcessController-threads"), Boolean.FALSE, null, "%G - %t", null, null, AccessController.getContext());
configuration.setThreadFactory(threadFactory);
configuration.setReadExecutor(Executors.newCachedThreadPool(threadFactory));

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

@Override
  public ThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup(SessionExpirationScheduler.class.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

相关文章

微信公众号

最新文章

更多