ThreadFactory

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadFactory {
    private static ExecutorService threadpool = Executors.newFixedThreadPool(200);

    public static ExecutorService getThreadpool() {
        return threadpool;
    }
}
时间: 2024-12-28 16:32:19

ThreadFactory的相关文章

Java并发包学习一 ThreadFactory介绍

ThreadFactory翻译过来是线程工厂,顾名思义,就是用来创建线程的,它用到了工厂模式的思想.它通常和线程池一起使用,主要用来控制创建新线程时的一些行为,比如设置线程的优先级,名字等等.它是一个接口,接口中只有一个方法: /* * * * * * * Written by Doug Lea with assistance from members of JCP JSR-166 * Expert Group and released to the public domain, as expl

使用java.util.concurrent.ThreadFactory类创建线程

工厂设计模式是Java中最常用的设计模式之一.它是一种创建型设计模式,能够用于创建一个或多个类所需要的对象.有了这个工厂,我们就能集中的创建对象. 集中创建方式给我们带来了一些好处,例如: 1. 能够很容易的改变类创建的对象或者创建对象的方式: 2. 能够很容易限制对象的创建,例如:我们只能为a类创建N个对象: 3. 能够很容易的生成有关对象创建的统计数据. 在Java中,我们通常使用两种方式来创建线程:继承Thread类和实现Runnable接口.Java还提供了一个接口,既ThreadFac

Java多线程之-----实现自己的ThreadFactory

工厂模式是最常用的模式之一,在创建线程的时候,我们当然也能使用工厂模式来生产Thread,这样就能替代默 认的new THread,而且在自定义工厂里面,我们能创建自定义化的Thread,并且计数,或则限制创建Thread的数量, 给每个Thread设置对应的好听的名字,或则其他的很多很多事情,总之就是很爽,下面我们来展示一个简单的Thread 工厂模式来创建自己的Thread. package com.bird.concursey; import java.util.ArrayList; im

Java ThreadFactory接口用法

根据需要创建新线程的对象.使用线程工厂就无需再手工编写对 new Thread 的调用了,从而允许应用程序使用特殊的线程子类.属性等等. JDK中的介绍: An object that creates new threads on demand. Using thread factories removes hardwiring of calls tonew Thread, enabling applications to use special thread subclasses, prior

Java使用ThreadFactory来创建新的线程

首先来构建线程封装类WorkThread,该类的功能主要是为了能够更好的管理线程而创建的 public class WorkThread extends Thread {       private Runnable target;   //线程执行目标     private AtomicInteger counter;         public WorkThread(Runnable target, AtomicInteger counter) {           this.targ

ThreadFactory的理解

ThreadFactory:就像一个代理类.在创建一个线程的时候,通过实现ThreadFactory接口的类对象,就会监听到它,从而执行ThreadFactory的newThread(Runnable  r)方法.把该线程传人方法中,你就可以在方法中对线程进行一些操作(如,给线程起名字,把线程封装到那个组,修改线程的优先级等等.)最后会把包装过的线程,放入jvm中去执行. 首先来构建线程封装类WorkThread,该类的功能主要是为了能够更好的管理线程而创建的 ? 1 2 3 4 5 6 7 8

重写ThreadFactory方法和拒绝策略

最近项目中要用到多线程处理任务,自然就用到了ThreadPoolTaskExecutor这个对象,这个是spring对于Java的concurrent包下的ThreadPoolExecutor类的封装,对于超出等待队列大小的任务默认是使用RejectedExecutionHandler去处理拒绝的任务,而这个Handler的默认策略是AbortPolicy,直接抛出RejectedExecutionException异常,这个不符合我们的业务场景, 业务需求:我希望是对于超出的任务,主线程进行阻

实现ThreadFactory接口生成自定义的线程给Fork/Join框架

Fork/Join框架是Java7中最有趣的特征之一.它是Executor和ExecutorService接口的一个实现,允许你执行Callable和Runnable任务而不用管理这些执行线程.这个执行者面向执行能被拆分成更小部分的任务.主要组件如下: 一个特殊任务,实现ForkJoinTask类 两种操作,将任务划分成子任务的fork操作和等待这些子任务结束的join操作 一个算法,优化池中线程的使用的work-stealing算法.当一个任务正在等待它的子任务(结束)时,它的执行线程将执行其

线程池的创建

package com.newer.cn; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Test1 { public static void main(String[] args) { // 创建线程池的方式 // 创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程,在需要时使用提供的 ThreadFactory 创建新线程. E