使用线程池简单用法

2022-08-07 20:00:09 阅读：151 来源： 互联网

标签：executor singleThreadPool 用法线程简单 test new public

1.springboot

配置

@EnableAsync    // 启用 Spring 的异步方法执行功能
@Configuration
public class ExecutorConfig {

@Bean("asyncExecutor")
public Executor asyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    // 配置核心线程数量
    executor.setCorePoolSize(3);
    // 配置最大线程数
    executor.setMaxPoolSize(5);
    // 配置队列容量
    executor.setQueueCapacity(1);
    // 配置空闲线程存活时间
    executor.setKeepAliveSeconds(60);

    executor.setAllowCoreThreadTimeOut(false);

    // 设置拒绝策略，直接在execute方法的调用线程中运行被拒绝的任务
    executor.setRejectedExecutionHandler(new org.apache.tomcat.util.threads.ThreadPoolExecutor.CallerRunsPolicy());

    // 执行初始化
    executor.initialize();
    return executor;
}

service

@Service
@RequiredArgsConstructor(onConstructor_ = {@Autowired})
@Slf4j
public class TestService   {

    @Async("asyncExecutor")
    public void test() {

        try {
            for (int i = 0; i <11 ; i++) {
                log.info("{}",i);

                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
}

controller

@Slf4j
@Validated
@RestController
@RequestMapping("/remote")
@Api(tags = "远程调用管理")
@RequiredArgsConstructor(onConstructor_ = {@Autowired})
public class RemoteController {

 @Autowired
    private TestService testService;
    @PostMapping("/test")
    @ApiOperation("测试")
    public Result test() {
        testService.test();
        return Result.ok();
    }
}

　结果，调用成功了，但是后台还在异步执行程序。

2.jfinal

启动后就设置线程，并且设置全局变量。

@Override
	public void afterJFinalStart() {
		//重新解析未知的知识点
		//TimerManager.AnalysisTimerManager(false);
		
		//TimerManager.AutomatiParsingManager(false);
		
		//TimerManager.wikiTimerManager(false);

		ScheduledExecutorService service = new ScheduledThreadPoolExecutor(1,new
				BasicThreadFactory.Builder().namingPattern("example-schedule-pool-%d").daemon(true).build());

		service.scheduleAtFixedRate(new TypeTemplateService(), 1, 10, TimeUnit.MINUTES);


		//设置线程池
		ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
				.setNameFormat("demo-pool-%d").build();
		ExecutorService singleThreadPool = new ThreadPoolExecutor(5, Integer.MAX_VALUE,
				60L, TimeUnit.MILLISECONDS,
				new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());


		ServletContext servletContext= JFinal.me().getServletContext() ;
		servletContext.setAttribute("singleThreadPool",singleThreadPool);


	}

使用

public class CommonController extends Controller {
   
    /**
     * @Author coco
     * @Description //线程池的使用案例。
     * @Date 2022/7/20 15:38
     **/
	public void test(){
　　　　//获取全局变量
        ServletContext servletContext= JFinal.me().getServletContext() ;
        ExecutorService singleThreadPool= (ExecutorService) servletContext.getAttribute("singleThreadPool");
        System.out.println(singleThreadPool);
        singleThreadPool.execute(()->{
            for (int i = 0; i < 10; i++) {

                System.out.println("test1"+i);
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        renderJson(MsgUtil.successMsg("test1"));

    }

}

结果，调用成功了，但是后台还在异步执行程序。

标签：executor,singleThreadPool,用法,线程,简单,test,new,public
来源： https://www.cnblogs.com/MetaVers/p/16559763.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

使用线程池简单用法