Skip to content

T
twitter_syncer
Commit 76bc7503 authored by vicotor's avatar vicotor
Browse files
Options

update syncer

parent 2b2c3b48
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
core/task.go
View file @ 76bc7503
...@@ -83,7 +83,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} { ...@@ -83,7 +83,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} {
cli := swarm.GetSwarm() cli := swarm.GetSwarm()
secondTicker := time.NewTicker(time.Minute * 3) secondTicker := time.NewTicker(time.Second * 20)
fiveMinutesTicker := time.NewTicker(time.Minute * 1) fiveMinutesTicker := time.NewTicker(time.Minute * 1)
halfHourTicker := time.NewTicker(time.Minute * 30) halfHourTicker := time.NewTicker(time.Minute * 30)
first := true first := true
...@@ -146,7 +146,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} { ...@@ -146,7 +146,7 @@ func (w *Work) RunJob(t TaskJob) chan<- interface{} {
Date: time.Now(), Date: time.Now(),
FollowCount: fc, FollowCount: fc,
}) })
secondTicker.Reset(time.Minute * 3) secondTicker.Reset(time.Minute * 1)
// 先用和like retweet一样的周期模式； // 先用和like retweet一样的周期模式；
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment