• 大小: 31KB
    文件类型: .rar
    金币: 1
    下载: 0 次
    发布日期: 2021-06-06
  • 语言: Java
  • 标签: RxJava  线程池  

资源简介

RxJava替换Schedulers.IO线程池,增加监控管理。 关于custominterface包:自定义IO scheduler或者scheduler所使用的线程池时,需要关注这个包下面的接口和抽象类 customScheduler包:已经自定义好的scheduler相关以及提供的基础线程池,可以参考这里的实现,去自定义应用自己的线程池管理的scheduler 大部分时候你只需要关心IOMonitorManager这个入口管理类,其它只在需要自定义或者策略改动时才修改。

资源截图

代码片段和文件信息

package com.xtc.snmonitor.collector.monitor.thread.monitorimpl;

import com.xtc.snmonitor.collector.monitor.thread.monitorimpl.custominterface.IOTaskPriorityType;

import rx.Scheduler;

/**
 * author:   tc
 * date:      2019/3/13 & 20:25
 * version    1.0
 * description 如果只是想直接使用自己的线程池的话,用这个类直接获取已有的Rx调度器
 * modify by
 */
public class AppSchedulers {

    public static Scheduler io(String taskTag @IOTaskPriorityType int priority) {
        return IOMonitorManager.getInstance().getIOScheduler(taskTag priority);
    }

    public static Scheduler io() {
        return IOMonitorManager.getInstance().getIOScheduler();
    }

    public static Scheduler immediate() {
        //目前不替换,使用原始的
        return rx.schedulers.Schedulers.immediate();
    }

    public static Scheduler computation() {
        //目前不替换,使用原始的
        return rx.schedulers.Schedulers.computation();
    }

    public static Scheduler newThread() {
        //目前不替换,使用原始的
        return rx.schedulers.Schedulers.newThread();
    }


}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1184  2019-04-10 09:41  monitorimpl\AppSchedulers.java

     文件       1692  2019-04-02 11:18  monitorimpl\custominterface\AbstractRejectedExecutionHandler.java

     文件       2009  2019-04-22 15:27  monitorimpl\custominterface\AbstractScheduler.java

     文件       2606  2019-04-09 17:14  monitorimpl\custominterface\AbstractThreadFactory.java

     文件       1077  2019-04-02 11:18  monitorimpl\custominterface\CustomThread.java

     文件        932  2019-06-12 11:21  monitorimpl\custominterface\IbaseWork.java

     文件       2316  2019-06-12 14:23  monitorimpl\custominterface\IORunnableTask.java

     文件       2158  2019-04-22 16:54  monitorimpl\custominterface\IOTaskPriorityType.java

     文件       1534  2019-04-22 14:48  monitorimpl\custominterface\IThreadPool.java

     文件       6040  2019-04-17 15:08  monitorimpl\custominterface\MonitorThreadPoolExecutor.java

     文件       9855  2019-06-12 14:28  monitorimpl\customScheduler\ExecutorSchedulerWorker.java

     文件       1734  2019-04-02 11:18  monitorimpl\customScheduler\GenericScheduledExecutorService.java

     文件       1528  2019-04-04 11:59  monitorimpl\customScheduler\IOScheduler.java

     文件       6553  2019-06-10 17:08  monitorimpl\customScheduler\LimitCoreThreadPool.java

     文件      13239  2019-04-22 17:09  monitorimpl\customScheduler\TwoThreadPool.java

     文件       1664  2019-04-17 15:08  monitorimpl\IOMonitorConstants.java

     文件      29510  2019-06-12 14:36  monitorimpl\IOMonitorManager.java

     文件       2067  2019-04-02 11:18  monitorimpl\queue\IOLimitArrayQueue.java

     文件       3351  2019-06-12 14:41  monitorimpl\queue\IOPriorityQueue.java

     文件       1548  2019-04-02 11:18  monitorimpl\readme

     文件        851  2019-04-10 09:41  monitorimpl\RxJavaSchedulersHookImpl.java

     文件       3987  2019-05-08 09:34  monitorimpl\ThreadPoolUtil.java

     目录          0  2019-06-12 14:23  monitorimpl\custominterface

     目录          0  2019-06-12 14:28  monitorimpl\customScheduler

     目录          0  2019-06-12 14:41  monitorimpl\queue

     目录          0  2019-06-12 14:36  monitorimpl

----------- ---------  ---------- -----  ----

                97435                    26


评论

共有 条评论