本文将分享聊聊chronos的DeleteBgWorker的详细内容，并且还将对chronodisruption进行详尽解释，此外，我们还将为大家带来关于android.widget.Chronome

本文将分享聊聊 chronos 的 DeleteBgWorker的详细内容，并且还将对chronodisruption进行详尽解释，此外，我们还将为大家带来关于android.widget.Chronometer.OnChronometerTickListener的实例源码、Apache Spark：“未能启动org.apache.spark.deploy.worker.Worker”或Master、attachment delete deletion commit work issue、BackgroundWorker RunWorkerCompleted事件的相关知识，希望对你有所帮助。

• 聊聊 chronos 的 DeleteBgWorker（chronodisruption）
• android.widget.Chronometer.OnChronometerTickListener的实例源码
• Apache Spark：“未能启动org.apache.spark.deploy.worker.Worker”或Master
• attachment delete deletion commit work issue
• BackgroundWorker RunWorkerCompleted事件

聊聊 chronos 的 DeleteBgWorker（chronodisruption）

序

本文主要研究一下 chronos 的 DeleteBgWorker

DeleteBgWorker

DDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/workers/DeleteBgWorker.java

public class DeleteBgWorker {
    private static final Logger LOGGER = LoggerFactory.getLogger(DeleteBgWorker.class);

    private static final DeleteConfig DELETE_CONFIG = ConfigManager.getConfig().getDeleteConfig();
    private static final int SAVE_HOURS_OF_DATA = DELETE_CONFIG.getSaveHours();
    private static final long INITIAL_DELAY_MINUTES = 1; // 1 分钟
    private static final long PERIOD_MINUTES = 10;       // 10 分钟

    private static volatile DeleteBgWorker instance = null;
    private static final SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    /**
     * 2017/10/13 00:00:00
     */
    private static final long MIN_TIMESTAMP = 1507824000;

    private static final ScheduledExecutorService SCHEDULE = new ScheduledThreadPoolExecutor(1,
            new BasicThreadFactory.Builder().namingPattern("delete-bg-worker-schedule-%d").daemon(true).build());

    private DeleteBgWorker() {
    }

    public void start() {
        SCHEDULE.scheduleAtFixedRate(() -> {
            byte[] beginKey = String.valueOf(MIN_TIMESTAMP).getBytes(Charsets.UTF_8);

            final long seekTimestampInSecond = MetaService.getSeekTimestamp();
            byte[] endKey = String.valueOf(seekTimestampInSecond - SAVE_HOURS_OF_DATA * 60 * 60).getBytes(Charsets.UTF_8);
            deleteRange(beginKey, endKey);
        }, INITIAL_DELAY_MINUTES, PERIOD_MINUTES, TimeUnit.MINUTES);
        LOGGER.info("DeleteBgWorker has started, initialDelayInMinutes:{}", INITIAL_DELAY_MINUTES);
    }

    private void deleteRange(final byte[] beginKey, final byte[] endKey) {
        LOGGER.info("deleteRange start, beginKey:{}, endKey:{}", new String(beginKey), new String(endKey));
        final long start = System.currentTimeMillis();
        RDB.deleteFilesInRange(CFManager.CFH_DEFAULT, beginKey, endKey);
        LOGGER.info("deleteRange end, beginKey:{}({}), endKey:{}({}), cost:{}ms",
                new String(beginKey), formatter.format(Long.parseLong(new String(beginKey)) * 1000),
                new String(endKey), formatter.format(Long.parseLong(new String(endKey)) * 1000),
                System.currentTimeMillis() - start);
    }

    public void stop() {
        SCHEDULE.shutdownNow();
        while (!SCHEDULE.isShutdown()) {
            LOGGER.info("DeleteBgWorker is shutting down!");
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                LOGGER.info("DeleteBgWorker was forced to shutdown, err:{}", e.getMessage(), e);
            }
        }
        LOGGER.info("DeleteBgWorker was shutdown!");
    }

    public static DeleteBgWorker getInstance() {
        if (instance == null) {
            synchronized (DeleteBgWorker.class) {
                if (instance == null) {
                    instance = new DeleteBgWorker();
                }
            }
        }
        return instance;
    }
}

• DeleteBgWorker 提供了静态方法 getInstance 来获取或创建单例，该类提供了 start、stop 两个方法；start 方法会往 SCHEDULE 注册一个调度任务，每隔 PERIOD_MINUTES 执行一次，它主要执行 deleteRange 方法；deleteRange 主要是执行 RDB.deleteFilesInRange (CFManager.CFH_DEFAULT, beginKey, endKey)，它会从 MetaService 获取 seekTimestamp 来计算 endKey；stop 方法则是关闭 SCHEDULE

deleteFilesInRange

DDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/db/RDB.java

public class RDB {
    private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(RDB.class);

    static RocksDB DB;

    //......

    public static boolean deleteFilesInRange(final ColumnFamilyHandle cfh, final byte[] beginKey,
                                             final byte[] endKey) {
        try {
            DB.deleteRange(cfh, beginKey, endKey);
            LOGGER.debug("succ delete range, columnFamilyHandle:{}, beginKey:{}, endKey:{}",
                    cfh.toString(), new String(beginKey), new String(endKey));
        } catch (RocksDBException e) {
            LOGGER.error("error while delete range, columnFamilyHandle:{}, beginKey:{}, endKey:{}, err:{}",
                    cfh.toString(), new String(beginKey), new String(endKey), e.getMessage(), e);
            return false;
        }
        return true;
    }

    //......
}

• deleteFilesInRange 方法主要是执行 DB.deleteRange (cfh, beginKey, endKey)

MetaService

DDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/services/MetaService.java

public class MetaService {
    private static final Logger LOGGER = LoggerFactory.getLogger(MetaService.class);

    private static volatile long seekTimestamp = -1;
    private static volatile long zkSeekTimestamp = -1;
    private static volatile Map<String, Long> zkQidOffsets = new ConcurrentHashMap<>();
    private static final DbConfig dbConfig = ConfigManager.getConfig().getDbConfig();

    private static final ScheduledExecutorService SCHEDULER = new ScheduledThreadPoolExecutor(1,
            new BasicThreadFactory.Builder().namingPattern("offset-seektimestamp-schedule-%d").daemon(true).build());

    public static void load() {
        final long start = System.currentTimeMillis();
        if (seekTimestamp == -1) {
            seekTimestamp = loadSeekTimestampFromFile();
        }
        final long cost = System.currentTimeMillis() - start;
        LOGGER.info("succ load seekTimestamp, seekTimestamp:{}, cost:{}ms", seekTimestamp, cost);

        SCHEDULER.scheduleWithFixedDelay(() -> {
            // 如果是master则拉取并上报zk offset和seekOffset
            if (MasterElection.isMaster()) {
                MqConsumeStatService.getInstance().uploadOffsetsToZk();
                uploadSeekTimestampToZk();
            }
        }, 5, 1, TimeUnit.SECONDS);
    }

    private static long loadSeekTimestampFromFile() {
        String seekTimestampStr = FileIOUtils.readFile2String(dbConfig.getSeekTimestampPath());
        if (StringUtils.isBlank(seekTimestampStr)) {
            final long initSeekTimestamp = TsUtils.genTS();
            boolean result = FileIOUtils.writeFileFromString(dbConfig.getSeekTimestampPath(), String.valueOf(initSeekTimestamp));
            if (result) {
                LOGGER.info("init seekTimestamp and succ save, current seekTimestamp:{}", initSeekTimestamp);
            } else {
                LOGGER.error("init seekTimestamp and fail to save, current seekTimestamp:{}", initSeekTimestamp);
            }
            return initSeekTimestamp;
        }
        LOGGER.info("succ load seekTimestamp from file, seekTimestamp:{}", Long.parseLong(seekTimestampStr));
        return Long.parseLong(seekTimestampStr);
    }

    public static long getSeekTimestamp() {
        return seekTimestamp;
    }

    /**
     * 此处的lock不能去掉
     * 判断消息超时时
     */
    public static void nextSeekTimestamp() {
        Batcher.lock.lock();
        try {
            seekTimestamp++;
            boolean result = FileIOUtils.writeFileFromString(dbConfig.getSeekTimestampPath(), String.valueOf(seekTimestamp));
            if (result) {
                LOGGER.info("incr seekTimestamp and succ save, next seekTimestamp:{}", seekTimestamp);
            } else {
                LOGGER.error("incr seekTimestamp and fail to save, next seekTimestamp:{}", seekTimestamp);
            }
        } finally {
            Batcher.lock.unlock();
        }
    }

    public static void uploadSeekTimestampToZk() {
        String seekTimestampStr = String.valueOf(MetaService.getSeekTimestamp());
        ZkUtils.createOrUpdateValue(Constants.SEEK_TIMESTAMP_ZK_PATH, seekTimestampStr);
        LOGGER.debug("upload seekTimestamp to zk, seekTimestamp:{}", seekTimestampStr);
    }

    public static Map<String, Long> getZkQidOffsets() {
        return zkQidOffsets;
    }

    public static void setZkQidOffsets(Map<String, Long> zkQidOffsets) {
        MetaService.zkQidOffsets = zkQidOffsets;
    }

    public static long getZkSeekTimestamp() {
        return zkSeekTimestamp;
    }

    public static void setZkSeekTimestamp(long zkSeekTimestamp) {
        MetaService.zkSeekTimestamp = zkSeekTimestamp;
    }
}

• MetaService 提供了 load、getSeekTimestamp、nextSeekTimestamp、uploadSeekTimestampToZk 等方法；load 方法在 seekTimestamp 为 - 1 时执行 loadSeekTimestampFromFile，之后注册一个定时任务每隔 1 秒，判断是否是 master，如果是则执行 MqConsumeStatService.getInstance ().uploadOffsetsToZk () 以及 uploadSeekTimestampToZk；nextSeekTimestamp 方法会先更新内存的 seekTimestamp，然后使用 FileIOUtils.writeFileFromString 将其值写入文件

小结

DeleteBgWorker 提供了静态方法 getInstance 来获取或创建单例，该类提供了 start、stop 两个方法；start 方法会往 SCHEDULE 注册一个调度任务，每隔 PERIOD_MINUTES 执行一次，它主要执行 deleteRange 方法；deleteRange 主要是执行 RDB.deleteFilesInRange (CFManager.CFH_DEFAULT, beginKey, endKey)，它会从 MetaService 获取 seekTimestamp 来计算 endKey；stop 方法则是关闭 SCHEDULE

doc

• carrera-chronos

android.widget.Chronometer.OnChronometerTickListener的实例源码

@Override
public View onCreateView(LayoutInflater inflater,ViewGroup container,Bundle savedInstanceState) {

    SharedPreferences sharedPref = getActivity().getSharedPreferences(getString(R.string.preference_file_key),Context.MODE_PRIVATE);
    mTime = sharedPref.getInt(getString(R.string.value_timer),mTime);
    View rootView = inflater.inflate(R.layout.fragment_layout_measurement,container,false);

    mStopWatch = (CustomStopwatch) rootView.findViewById(R.id.stopwatch);

    mStopWatch.setTime(mTime);
    mStopWatch.setonChronometerTickListener(new OnChronometerTickListener() {

                                                public void onChronometerTick(Chronometer arg0) {
                                                    boolean isAlert = false;
                                                    if (mStopWatch.measurementIsFinished() && !isAlert) {
                                                        mCallback.onTimerEnd(mTime);
                                                        stopTimer();
                                                        isAlert = true;
                                                    }
                                                }
                                            }
    );
    return rootView;
}

/**
 * 开始计时
 */
public void start() {
    // System.out.println("开始计时了。。。");
    // 显示录制时间的textview
    m_csbtn_recordtime.setVisibility(View.VISIBLE);
    // 计时器控件重新置数，并开始启动计时器
    m_chronometer_recordtime.setBase(SystemClock.elapsedRealtime());
    m_chronometer_recordtime.start();
    // 当背景改变是后背景改变
    m_chronometer_recordtime
            .setonChronometerTickListener(new OnChronometerTickListener() {
                // 记录录制时间变量
                @Override
                public void onChronometerTick(Chronometer chronometer) {
                    // Todo Auto-generated method stub

                    // 为显示录制时间的textview赋值
                    String time = chronometer.getText().toString();
                    System.out.println("time为" + time);
                    // 确保显示时间的格式为00:00:00
                    if (time.length() == 5) {
                        m_csbtn_recordtime.setText("00:"
                                + chronometer.getText());
                    } else if (time.length() == 7) {
                        m_csbtn_recordtime.setText("0"
                                + chronometer.getText());
                    } else if (time.length() == 8) {
                        m_csbtn_recordtime.setText(chronometer.getText());
                    }

                    if (WiCameraActivity.mCurrentDegree == 90||WiCameraActivity.mCurrentDegree == 270) {
                        WiCameraActivity.m_al_camera_overlayui
                                .postInvalidate();
                    }
                }

            });
}

@Override
public View onCreateView(LayoutInflater inflater,Bundle savedInstanceState) {
    fragmentView = (LinearLayout) inflater.inflate(R.layout.main,false);

    layout1 = (LinearLayout) fragmentView.findViewById(R.id.linearLayout1);
    layout2 = (LinearLayout) fragmentView.findViewById(R.id.linearLayout2);
    layout4 = (LinearLayout) fragmentView.findViewById(R.id.linearLayout4);
    layout5 = (LinearLayout) fragmentView.findViewById(R.id.linearLayout5);

    defineWidgets(fragmentView);

    if (savedInstanceState != null)
        chrono.setBase(chronoBaseValue);

    chrono.setonChronometerTickListener(new OnChronometerTickListener() {
        public void onChronometerTick(Chronometer arg0) {
            showCalculatedData(arg0);

            if (prefs.getInt("practice_display5",TypesOfPractices.BASIC_PRACTICE.getTypes()) == TypesOfPractices.HIIT_PRACTICE
                    .getTypes())
                showHiitTrainingDataIndisplay(arg0);
        }
    });

    mapView = (MapView) fragmentView.findViewById(R.id.practice_mapview);
    mapView.getoverlays().clear();
    mapView.setBuiltInZoomControls(true);
    mapView.setMultiTouchControls(true);
    mapView.setUseSafeCanvas(true);

    setHardwareaccelerationOff();

    mapController = (MapController) mapView.getController();

    ScaleBarOverlay mScaleBarOverlay = new ScaleBarOverlay(mContext);
    mapView.getoverlays().add(mScaleBarOverlay);

    pathOverlay = new PathOverlay(Color.BLUE,mContext);
    pathOverlay.getPaint().setStyle(Style.stroke);
    pathOverlay.getPaint().setstrokeWidth(3);
    pathOverlay.getPaint().setAntiAlias(true);
    mapView.getoverlays().add(pathOverlay);

    this.mCompassOverlay = new CompassOverlay(mContext,new InternalCompassOrientationProvider(mContext),mapView);
    mCompassOverlay.setEnabled(true);
    mapView.getoverlays().add(mCompassOverlay);

    this.mLocationOverlay = new MyLocationNewOverlay(mContext,new GpsMyLocationProvider(mContext),mapView);
    mLocationOverlay.setDrawAccuracyEnabled(true);
    mapView.getoverlays().add(mLocationOverlay);

    MapOverlay touchOverlay = new MapOverlay(mContext);
    mapView.getoverlays().add(touchOverlay);

    mLocationOverlay.runOnFirstFix(new Runnable() {
        public void run() {
            if (centerPoint == null)
                centerPoint = mLocationOverlay.getMyLocation();

            centerMyLocation(centerPoint);
        }
    });

    mapView.postInvalidate();

    return fragmentView;
}

@Override
protected void onStart() {
    // Todo Auto-generated method stub
    super.onStart();
    stopwatch.setonChronometerTickListener(new OnChronometerTickListener() {
        @Override
        public void onChronometerTick(Chronometer arg0) {

            int countup = (int) ((SystemClock.elapsedRealtime() - arg0
                    .getBase()) / 1000);
            String asText = (countup / 60) + ":" + (countup % 60);
            tvtimer.setText("Time Elapsed :- " + asText);
        }
    });
}

private void setonChronometer(){

        ch.setonChronometerTickListener(new OnChronometerTickListener() {
            @Override
            public void onChronometerTick(Chronometer chronometer) {
                long aux = SystemClock.elapsedRealtime() - chronometer.getBase();
                hmmss = timeFormat.format(aux); 
                chronometer.setText(hmmss);
            }
        });

    }

public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);



    getfigureFromPreferences();
    getTypeFromPreferences();
    musicOn();      
    play(); 
    oldfigure=Preferences.getfigureName(this);



    //ActionBar actionbar=getActionBar(); //SDK 11 Needed!


        setStopWatch((Chronometer) findViewById(R.id.chrono));
       startTime = SystemClock.elapsedRealtime();

       //textGoesHere = (TextView) findViewById(R.id.textGoesHere);
       getStopWatch().setonChronometerTickListener(new OnChronometerTickListener(){
           @Override
           public void onChronometerTick(Chronometer arg0) {
               countUp = (SystemClock.elapsedRealtime() - arg0.getBase()) / 1000;
               //String asText = (countUp / 60) + ":" + (countUp % 60); 
              // textGoesHere.setText(asText);
               game.setSeconds((int)countUp);
               setPlayerNameFromsetUPreferences();
               game.setCurrentPlayer(playerName);
           }
       });

       getStopWatch().start();




}

Apache Spark：“未能启动org.apache.spark.deploy.worker.Worker”或Master