首先這個(gè)具體日期是和這個(gè)時(shí)間應(yīng)該是一一對(duì)應(yīng)的關(guān)系,下周三應(yīng)該有一個(gè)具體的數(shù)據(jù)和日期一一對(duì)應(yīng),比如說下周三是今年的具體的第幾天,然后就可以計(jì)算出當(dāng)時(shí)的日期了。比如:
目前創(chuàng)新互聯(lián)公司已為超過千家的企業(yè)提供了網(wǎng)站建設(shè)、域名、虛擬空間、網(wǎng)站運(yùn)營、企業(yè)網(wǎng)站設(shè)計(jì)、西崗網(wǎng)站維護(hù)等服務(wù),公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
// 2022年第一天
day := time.Date(2022, 1, 1, 0, 0, 0, 0, time.Local)
// 2022年的第304天
days := 304
// 2022年第304天的日期
expectedDay := day.Add(time.Duration(days*24*3600) * time.Second)
// 這一天是星期幾
fmt.Println(expectedDay.Weekday())
// 這一天的日期
fmt.Println(expectedDay.Date())
這樣。不過只是個(gè)精確到納秒的計(jì)時(shí)器,不是精確到納秒的當(dāng)前時(shí)間。windows好像只能拿到ms精度的當(dāng)前時(shí)間吧,不是很清楚。
package main
import (
"syscall"
"time"
"unsafe"
)
func NewStopWatch() func() time.Duration {
var QPCTimer func() func() time.Duration
QPCTimer = func() func() time.Duration {
lib, _ := syscall.LoadLibrary("kernel32.dll")
qpc, _ := syscall.GetProcAddress(lib, "QueryPerformanceCounter")
qpf, _ := syscall.GetProcAddress(lib, "QueryPerformanceFrequency")
if qpc == 0 || qpf == 0 {
return nil
}
var freq, start uint64
syscall.Syscall(qpf, 1, uintptr(unsafe.Pointer(freq)), 0, 0)
syscall.Syscall(qpc, 1, uintptr(unsafe.Pointer(start)), 0, 0)
if freq = 0 {
return nil
}
freqns := float64(freq) / 1e9
return func() time.Duration {
var now uint64
syscall.Syscall(qpc, 1, uintptr(unsafe.Pointer(now)), 0, 0)
return time.Duration(float64(now-start) / freqns)
}
}
var StopWatch func() time.Duration
if StopWatch = QPCTimer(); StopWatch == nil {
// Fallback implementation
start := time.Now()
StopWatch = func() time.Duration { return time.Since(start) }
}
return StopWatch
}
func main() {
// Call a new stop watch to create one from this moment on.
watch := NewStopWatch()
// Do some stuff that takes time.
time.Sleep(1)
// Call the stop watch itself and it will return a time.Duration
dur := watch()
}
這和語言沒關(guān)系,操作系統(tǒng)要提供這樣的原語。linux和windows都是可以的。
在linux下實(shí)現(xiàn)定時(shí)器主要有如下方式
在這當(dāng)中 基于時(shí)間輪方式實(shí)現(xiàn)的定時(shí)器 時(shí)間復(fù)雜度最小,效率最高,然而我們可以通過 優(yōu)先隊(duì)列 實(shí)現(xiàn)時(shí)間輪定時(shí)器。
優(yōu)先隊(duì)列的實(shí)現(xiàn)可以使用最大堆和最小堆,因此在隊(duì)列中所有的數(shù)據(jù)都可以定義排序規(guī)則自動(dòng)排序。我們直接通過隊(duì)列中 pop 函數(shù)獲取數(shù)據(jù),就是我們按照自定義排序規(guī)則想要的數(shù)據(jù)。
在 Golang 中實(shí)現(xiàn)一個(gè)優(yōu)先隊(duì)列異常簡單,在 container/head 包中已經(jīng)幫我們封裝了,實(shí)現(xiàn)的細(xì)節(jié),我們只需要實(shí)現(xiàn)特定的接口就可以。
下面是官方提供的例子
因?yàn)閮?yōu)先隊(duì)列底層數(shù)據(jù)結(jié)構(gòu)是由二叉樹構(gòu)建的,所以我們可以通過數(shù)組來保存二叉樹上的每一個(gè)節(jié)點(diǎn)。
改數(shù)組需要實(shí)現(xiàn) Go 預(yù)先定義的接口 Len , Less , Swap , Push , Pop 和 update 。
timerType結(jié)構(gòu)是定時(shí)任務(wù)抽象結(jié)構(gòu)
首先的 start 函數(shù),當(dāng)創(chuàng)建一個(gè) TimeingWheel 時(shí),通過一個(gè) goroutine 來執(zhí)行 start ,在start中for循環(huán)和select來監(jiān)控不同的channel的狀態(tài)
通過for循環(huán)從隊(duì)列中取數(shù)據(jù),直到該隊(duì)列為空或者是遇見第一個(gè)當(dāng)前時(shí)間比任務(wù)開始時(shí)間大的任務(wù), append 到 expired 中。因?yàn)閮?yōu)先隊(duì)列中是根據(jù) expiration 來排序的,
所以當(dāng)取到第一個(gè)定時(shí)任務(wù)未到的任務(wù)時(shí),表示該定時(shí)任務(wù)以后的任務(wù)都未到時(shí)間。
當(dāng) getExpired 函數(shù)取出隊(duì)列中要執(zhí)行的任務(wù)時(shí),當(dāng)有的定時(shí)任務(wù)需要不斷執(zhí)行,所以就需要判斷是否該定時(shí)任務(wù)需要重新放回優(yōu)先隊(duì)列中。 isRepeat 是通過判斷任務(wù)中 interval 是否大于 0 判斷,
如果大于0 則,表示永久就生效。
防止外部濫用,阻塞定時(shí)器協(xié)程,框架又一次封裝了timer這個(gè)包,名為 timer_wapper 這個(gè)包,它提供了兩種調(diào)用方式。
參數(shù)和上面的參數(shù)一樣,只是在第三個(gè)參數(shù)中使用了任務(wù)池,將定時(shí)任務(wù)放入了任務(wù)池中。定時(shí)任務(wù)的本身執(zhí)行就是一個(gè) put 操作。
至于put以后,那就是 workers 這個(gè)包管理的了。在 worker 包中, 也就是維護(hù)了一個(gè)任務(wù)池,任務(wù)池中的任務(wù)會(huì)有序的執(zhí)行,方便管理。