com.yishuifengxiao.common.crawler

Class CrawlerProcessor

java.lang.Object

java.lang.Thread

com.yishuifengxiao.common.crawler.CrawlerProcessor

All Implemented Interfaces:

Runnable

public class CrawlerProcessor
extends Thread

风铃虫处理器
负责调用线程池使用多线程进行风铃虫任务处理

Version:

1.0.0

Author:

yishui

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	failCount 本实例解析失败的任务数据
protected AtomicLong	taskCount 本实例解析成功的任务数据

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CrawlerProcessor(Crawler crawler, ThreadPoolExecutor threadPool)

Method Summary

Modifier and Type	Method and Description
protected int	getActiveCount() 获取到风铃虫线程池里最大活跃的线程数
protected Statu	getStatu() 获取实例的状态
ThreadPoolExecutor	getThreadPool() 获取线程池
protected boolean	isActive() 判断此处理器是否处于活跃状态
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

taskCount

protected final AtomicLong taskCount

本实例解析成功的任务数据

failCount

protected final AtomicLong failCount

本实例解析失败的任务数据

Constructor Detail

CrawlerProcessor

public CrawlerProcessor(Crawler crawler,
                        ThreadPoolExecutor threadPool)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getStatu

protected Statu getStatu()

获取实例的状态

Returns:

实例的状态

getActiveCount

protected int getActiveCount()

获取到风铃虫线程池里最大活跃的线程数

Returns:

isActive

protected boolean isActive()

判断此处理器是否处于活跃状态

Returns:

当处理器线程为活着且线程池里的活跃线程数大于0时才认为任务没有处理完

getThreadPool

public ThreadPoolExecutor getThreadPool()

获取线程池

Returns: