zoukankan      html  css  js  c++  java
  • Elasticsearch+Spring定时任务报错【not be the scheduler thread. Reason: [Blocking operation]】

    报错

    java.lang.AssertionError: Expected current thread [Thread[scheduler-5,5,main]] to not be the scheduler thread. Reason: [Blocking operation]
    	at org.elasticsearch.threadpool.ThreadPool.assertNotScheduleThread(ThreadPool.java:787) ~[elasticsearch-5.2.2.jar:5.2.2]
    	at org.elasticsearch.common.util.concurrent.BaseFuture.get(BaseFuture.java:65) ~[elasticsearch-5.2.2.jar:5.2.2]
    	at org.elasticsearch.action.support.AdapterActionFuture.actionGet(AdapterActionFuture.java:68) ~[elasticsearch-5.2.2.jar:5.2.2]
    

    原因

    代码
    client.prepareExists(indexname).execute().actionGet();
    org.elasticsearch.common.util.concurrent.BaseFuture中调用ThreadPool.assertNotScheduleThread(BLOCKING_OP_REASON)保证其不为"schedule"线程(猜想:避免阻塞调度线程?)。

     <task:scheduler id="taskController" pool-size="20"/>
    

    因此修改scheduler为其他名字即可。

    解决

    重新new一个线程或者修改beanName以改变线程名前缀。

    <task:scheduler id="otherName" pool-size="10"/>
    

    ExecutorConfigurationSupport#afterPropertiesSet会保证将beanName作为线程的前缀。

    	/**
    	 * Set up the ExecutorService.
    	 */
    	public void initialize() {
    		if (logger.isInfoEnabled()) {
    			logger.info("Initializing ExecutorService " + (this.beanName != null ? " '" + this.beanName + "'" : ""));
    		}
    		if (!this.threadNamePrefixSet && this.beanName != null) {
    			setThreadNamePrefix(this.beanName + "-");
    		}
    		this.executor = initializeExecutor(this.threadFactory, this.rejectedExecutionHandler);
    	}
    
    

    为了防止阻塞调度线程,再将代码 actionGet/get添加了超时时间

  • 相关阅读:
    分类和预测
    机器学习&数据挖掘笔记_16(常见面试之机器学习算法思想简单梳理)
    字符串匹配的KMP算法
    灰度共生矩阵提取纹理特征源码
    redis永不过期,保留最新5条数据,StringUtils.join()等总结
    Session问题以及解决方案
    spring boot 配置 log4j2
    每日知识记载总结54
    spring cloud踩坑指南
    每日知识记载总结53
  • 原文地址:https://www.cnblogs.com/thewindkee/p/12873111.html
Copyright © 2011-2022 走看看