tasks

package
v0.0.0-...-627f02a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 31, 2016 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

构建索引

Author: Aosen Data: 2016-2-2 Desc: novel 任务列表 golang下有大神提供的cron库, go下的cron库使用的是 github.com/robfig/cron, 最终使用的是 github.com/jakecoffman/cron, 后者也是前者的改进版,主要增加了个RemoveJob的函数来移除特定的任务。 http://ju.outofmemory.cn/entry/65356

使用示例:

c := cron.New()
spec := "*/5 * * * * ?"
c.AddFunc(spec, func() {
    i++
    log.Println("cron running:", i)
})
c.Start()

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SysTask

func SysTask(settings map[string]string)

执行定时器任务

Types

type IndexTask

type IndexTask struct {
	// contains filtered or unexported fields
}

func NewIndexTask

func NewIndexTask(searcher *search.Engine) *IndexTask

func (*IndexTask) Index

func (self *IndexTask) Index()

type ManagementCenter

type ManagementCenter struct {
	Queue chan *Task
	//协程数
	Number int
	//任务队列最大容量
	Total int
}

func NewManagementCenter

func NewManagementCenter(number, total int) *ManagementCenter

生成一个管理中心

func (*ManagementCenter) AddTask

func (self *ManagementCenter) AddTask(task *Task)

添加任务

func (*ManagementCenter) Start

func (self *ManagementCenter) Start()

管理器开始运行

func (*ManagementCenter) Stop

func (self *ManagementCenter) Stop()

关门送客

type RankTask

type RankTask struct {
}

func NewRankTask

func NewRankTask() *RankTask

func (*RankTask) CollectRank

func (self *RankTask) CollectRank()

func (*RankTask) PVRank

func (self *RankTask) PVRank()

type Task

type Task struct {
	Execut func(docid uint64, arg string)
	Arg    string
	Docid  uint64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL