zoukankan      html  css  js  c++  java
  • ScheduledExecutorService类的使用

    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    
    public class TaskScheduler {
    
        private static ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(5);
    
        /**
         * @param args
         */
        public static void main(String[] args) {
    //        System.out.print(System.currentTimeMillis());
            // 每秒生成固定数目的数据量,每种数据的数据量可配置
            MetadataTask humanTask = new MetadataTask(Metadata2KafkaTask.TARGET_TYPE_HUMAN);
            MetadataTask vehicleTask = new MetadataTask(Metadata2KafkaTask.TARGET_TYPE_VEHICLE);
    //        VehiclePassData2KafkaTask vehiclePassTask = new VehiclePassData2KafkaTask();
    //        VehicleAlarmData2KafkaTask vehicleAlarmTask = new VehicleAlarmData2KafkaTask();
    
            scheduledExecutor.scheduleAtFixedRate(humanTask, 0, 1000, TimeUnit.MILLISECONDS);
            scheduledExecutor.scheduleAtFixedRate(vehicleTask, 0, 1000, TimeUnit.MILLISECONDS);
    //        scheduledExecutor.scheduleAtFixedRate(vehiclePassTask, 400, 1000, TimeUnit.MILLISECONDS);
    //        scheduledExecutor.scheduleAtFixedRate(vehicleAlarmTask, 800, 1000, TimeUnit.MILLISECONDS);
        }
    
    }
  • 相关阅读:
    Using NAT between the vCenter Server system and ESXi/ESX hosts (1010652)
    Zabbix监控windows进程连接数
    CentOS yum [Errno 14] problem making ssl connection CentOs
    httpSecurity
    Nginx
    线程基础知识
    SqlServler
    关于数据库索引
    Https的底层原理
    Synchronized
  • 原文地址:https://www.cnblogs.com/jinniezheng/p/6397707.html
Copyright © 2011-2022 走看看