先上個呼叫例子:

//函式執行模板
//author: Xiong Chuan Liang
//date: 2015-3-19

package main

import (
	"fmt"
	"log"
	"os"

	"utils"
)

func main() {
	log.SetOutput(os.Stdout)

	w := utils.NewWorker()
	w.Run("myPrintf()", myPrintf, "aa", "bb")

}

func myPrintf(args ...interface{}) (int, error) {
	fmt.Println("myPrintf() begin.")
	for _, arg := range args {
		fmt.Println("args:", arg)
	}
	fmt.Println("myPrintf() end.")
	panic("嘗試丟擲panic錯誤")
	return 0, nil
}

/*
執行結果:

2015/03/19 13:49:30 [worker.Run()] 函式: myPrintf()
myPrintf() begin.
args: aa
args: bb
myPrintf() end.
2015/03/19 13:49:30 [worker.Run()] panic:
 myPrintf()
 嘗試丟擲panic錯誤
2015/03/19 13:49:30 [worker.Run()] 函式:myPrintf() 耗時:0.004000 秒

*/
 

   實現也很簡單:

//函式執行模板
//author: Xiong Chuan Liang
//date: 2015-3-19

package utils

import (
	"fmt"
	"log"
	"time"
)

type workerFunc func(...interface{}) (int, error)

type worker struct {
}

func NewWorker() *worker {
	return &worker{}
}

func (w *worker) Run(name string, workerFunc workerFunc, args ...interface{}) (int, error) {

	now := time.Now()
	log.Println("[worker.Run()] 函式:", name)

	defer func() {
		if r := recover(); r != nil {
			log.Println("[worker.Run()] panic:\n", name, "\n", fmt.Sprint(r))
			w.elasped(name, now, time.Now())
		}
	}()

	ret, err := workerFunc(args...)
	w.elasped(name, now, time.Now())
	return ret, err
}

func (w *worker) elasped(name string, beginTime, endTime time.Time) {
	log.Printf("[worker.Run()] 函式:%s 耗時:%f 秒 \n",
		name, endTime.Sub(beginTime).Seconds())
}
 

    沒多少東西，我也就處理func(...interface{}) (int, error)這類函式，其它沒管了。

BLOG: http://blog.csdn.net/xcl168

MAIL: [email protected]