zoukankan      html  css  js  c++  java
  • 基于ScheduledExecutorService的并发定时任务处理能力测试

    测试代码

    定时器类

    package business.util; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import transfer.IUserParser; public class MyTimer { private static ScheduledExecutorService ses = Executors .newSingleThreadScheduledExecutor();

    // .newScheduledThreadPool(10); private MyTimer() { } / * 设置某一parser正在执行脚本的超时时间 * * @param parser * 进行超时控制的解析器 * @param timeout * 超时时间,单位:秒 * @return */ public static ScheduledFuture<?> set(IUserParser parser, int timeout) { CloseRutine routine = new CloseRutine(parser); ScheduledFuture<?> job = ses.schedule(routine, timeout, TimeUnit.SECONDS); return job; } / * 清除计时器 * * @param unit * @return / public static boolean cancel(ScheduledFuture<?> job) { return job.cancel(true); } / * 关闭此计时器(进程) / public static void shutdown() { ses.shutdown(); } } class CloseRutine implements Runnable { private final IUserParser parser; CloseRutine(IUserParser parser) { this.parser = parser; } @Override public void run() { parser.closePeer(); } }

  • 相关阅读:
    matplotlib 可视化 —— matplotlib.patches
    Ansi,UTF8,Unicode,ASCII编码的差别
    java.lang.Runnable接口
    wikioi 1051哈希表
    具体解释协方差与协方差矩阵
    基于Android Fragment功能的样例
    大学让我们坠落
    FFTW库+VS2012配置
    Ubuntu下安装eclipse
    SoftReference
  • 原文地址:https://www.cnblogs.com/darkmatter/p/3606755.html
Copyright © 2011-2022 走看看