在批处理中编写HBase文件异步,数百万数据的正常情况,并且HBase可以在10s批次内写入10s,但是在线Kerberos身份验证有点问题,花了半小时才能使业务难以实现企业的困难人员会迅速感知任务执行的失败。如果线程的持续时间可能导致线程池耗尽系统的耗尽,或经常gc等。那么如何解决该线程任务超时的问题?
线程池 + CountDownLatch解决了线程执行超时的问题。简化业务中的场景并创建固定的 - 大小线程池。这里的场景相对清楚。您可以直接使用newFixedThreadPool。明确建议使用ALI编码规范来使用此信息,但是如果我们了解这些线程池的原理,在适当的场景中,我们将在适当的场景中。它仍然可以在下面使用。在下面创建一个线程池,请执行任务运行,睡觉60秒,创建一个CountDownLatch计数器。执行线程任务后,它将减少一个,但是我们设置了59秒的计数器,因此当线程达到59秒时,任务是任务,任务是任务,任务是任务,任务是任务,任务是任务,任务是任务。线程尚未执行,线程直接关闭,然后抛出异常。