|
@@ -228,7 +228,6 @@ func (this *CustomManager) newUserQueue(batchFlag string) {
|
|
|
func (this *CustomManager) DoSearch() {
|
|
func (this *CustomManager) DoSearch() {
|
|
|
log.Printf("[MANAGER-INFO]CustomManager DoSearch Start\n")
|
|
log.Printf("[MANAGER-INFO]CustomManager DoSearch Start\n")
|
|
|
for {
|
|
for {
|
|
|
-
|
|
|
|
|
var obj *SearchEntity
|
|
var obj *SearchEntity
|
|
|
select { //优先级 newRegisterUserQueue > activityUserQueue
|
|
select { //优先级 newRegisterUserQueue > activityUserQueue
|
|
|
case <-this.StopSearch: //不在运行时间段内退出查询
|
|
case <-this.StopSearch: //不在运行时间段内退出查询
|
wangkaiyue