本文整理了Java中org.jboss.threads.JBossThreadFactory
类的一些代码示例,展示了JBossThreadFactory
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JBossThreadFactory
类的具体详情如下:
包路径:org.jboss.threads.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);
}
});
内容来源于网络,如有侵权,请联系作者删除!