org.jboss.threads.JBossThreadFactory.<init>()方法的使用及代码示例

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

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

JBossThreadFactory.<init>介绍

[英]Construct a new instance. The access control context of the calling thread will be the one used to create new threads if a security manager is installed.
[中]构造一个新实例。如果安装了安全管理器,则调用线程的访问控制上下文将用于创建新线程。

代码示例

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

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

代码示例来源: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 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 JBossThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup("NamingEventCoordinator-threads"), Boolean.FALSE, null, "%G - %t", null, null);
  }
});

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

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

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

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

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

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

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

private static ThreadFactory createThreadFactory() {
  PrivilegedAction<ThreadFactory> action = () -> new JBossThreadFactory(new ThreadGroup(InfinispanSessionManager.class.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  return WildFlySecurityManager.doUnchecked(action);
}

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

private static ThreadFactory createThreadFactory(Class<?> targetClass) {
  PrivilegedAction<ThreadFactory> action = () -> new ClassLoaderThreadFactory(new JBossThreadFactory(new ThreadGroup(targetClass.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null), targetClass.getClassLoader());
  return WildFlySecurityManager.doUnchecked(action);
}

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

private static ThreadFactory createThreadFactory(Class<?> targetClass) {
  PrivilegedAction<ThreadFactory> action = () -> new ClassLoaderThreadFactory(new JBossThreadFactory(new ThreadGroup(targetClass.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null), targetClass.getClassLoader());
  return WildFlySecurityManager.doUnchecked(action);
}

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

private static ThreadFactory createThreadFactory(Class<?> targetClass) {
  PrivilegedAction<ThreadFactory> action = () -> new ClassLoaderThreadFactory(new JBossThreadFactory(new ThreadGroup(targetClass.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null), targetClass.getClassLoader());
  return WildFlySecurityManager.doUnchecked(action);
}

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

private static ThreadFactory createThreadFactory() {
  PrivilegedAction<ThreadFactory> action = () -> new JBossThreadFactory(new ThreadGroup(InfinispanBeanManager.class.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  return WildFlySecurityManager.doUnchecked(action);
}

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

private static ThreadFactory createThreadFactory(Class<?> targetClass) {
  PrivilegedAction<ThreadFactory> action = () -> new JBossThreadFactory(new ThreadGroup(targetClass.getSimpleName()), Boolean.FALSE, null, "%G - %t", null, null);
  return new ClassLoaderThreadFactory(WildFlySecurityManager.doUnchecked(action), targetClass.getClassLoader());
}

代码示例来源: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.wildfly.core/wildfly-controller

public JBossThreadFactory run() {
    return new JBossThreadFactory(new ThreadGroup("management-handler-thread"), 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-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: 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: 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: org.wildfly/wildfly-server

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

相关文章

微信公众号

最新文章

更多