Package us.codecraft.webmagic.scheduler
Class RedisPriorityScheduler
java.lang.Object
us.codecraft.webmagic.scheduler.DuplicateRemovedScheduler
us.codecraft.webmagic.scheduler.RedisScheduler
us.codecraft.webmagic.scheduler.RedisPriorityScheduler
- All Implemented Interfaces:
us.codecraft.webmagic.scheduler.component.DuplicateRemover,us.codecraft.webmagic.scheduler.MonitorableScheduler,us.codecraft.webmagic.scheduler.Scheduler
the redis scheduler with priority
- Author:
- sai Created by sai on 16-5-27.
-
Field Summary
Fields inherited from class us.codecraft.webmagic.scheduler.RedisScheduler
poolFields inherited from class us.codecraft.webmagic.scheduler.DuplicateRemovedScheduler
logger -
Constructor Summary
ConstructorsConstructorDescriptionRedisPriorityScheduler(String host) RedisPriorityScheduler(redis.clients.jedis.JedisPool pool) -
Method Summary
Modifier and TypeMethodDescriptionus.codecraft.webmagic.Requestpoll(us.codecraft.webmagic.Task task) protected voidpushWhenNoDuplicate(us.codecraft.webmagic.Request request, us.codecraft.webmagic.Task task) voidresetDuplicateCheck(us.codecraft.webmagic.Task task) Methods inherited from class us.codecraft.webmagic.scheduler.RedisScheduler
getItemKey, getLeftRequestsCount, getQueueKey, getSetKey, getTotalRequestsCount, isDuplicateMethods inherited from class us.codecraft.webmagic.scheduler.DuplicateRemovedScheduler
getDuplicateRemover, noNeedToRemoveDuplicate, push, setDuplicateRemover, shouldReservedMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface us.codecraft.webmagic.scheduler.Scheduler
push
-
Constructor Details
-
RedisPriorityScheduler
-
RedisPriorityScheduler
public RedisPriorityScheduler(redis.clients.jedis.JedisPool pool)
-
-
Method Details
-
pushWhenNoDuplicate
protected void pushWhenNoDuplicate(us.codecraft.webmagic.Request request, us.codecraft.webmagic.Task task) - Overrides:
pushWhenNoDuplicatein classRedisScheduler
-
poll
public us.codecraft.webmagic.Request poll(us.codecraft.webmagic.Task task) - Specified by:
pollin interfaceus.codecraft.webmagic.scheduler.Scheduler- Overrides:
pollin classRedisScheduler
-
resetDuplicateCheck
public void resetDuplicateCheck(us.codecraft.webmagic.Task task) - Specified by:
resetDuplicateCheckin interfaceus.codecraft.webmagic.scheduler.component.DuplicateRemover- Overrides:
resetDuplicateCheckin classRedisScheduler
-