go語言定時器間隔執(zhí)行,golang 定時執(zhí)行
golang 定時器，啟動的時候執(zhí)行一次，以后每天晚上12點執(zhí)行，怎么實現(xiàn)
func?startTimer(f?func())?{
創(chuàng)新互聯(lián)公司專注于企業(yè)網(wǎng)絡營銷推廣、網(wǎng)站重做改版、湯陰網(wǎng)站定制設計、自適應品牌網(wǎng)站建設、H5響應式網(wǎng)站、商城開發(fā)、集團公司官網(wǎng)建設、成都外貿(mào)網(wǎng)站建設公司、高端網(wǎng)站制作、響應式網(wǎng)頁設計等建站業(yè)務，價格優(yōu)惠性價比高，為湯陰等各大城市提供網(wǎng)站開發(fā)制作服務。
go?func()?{
for?{
f()
now?:=?time.Now()
//?計算下一個零點
next?:=?now.Add(time.Hour?*?24)
next?=?time.Date(next.Year(),?next.Month(),?next.Day(),?0,?0,?0,?0,?next.Location())
t?:=?time.NewTimer(next.Sub(now))
-t.C
}
}()
}
Go語言基于Etcd實現(xiàn)的定時任務
利用 Etcd 的Lease租約特性來實現(xiàn)定時功能，同時通過Watch機制來實現(xiàn)多節(jié)點情況下只有一個節(jié)點執(zhí)行該任務。通過定時任務庫 Cron 的時間字符串解析器Parser來解析任務執(zhí)行時間。
Etcd
Cron
源碼鏈接
Golang-基于TimeingWheel定時器
在linux下實現(xiàn)定時器主要有如下方式
在這當中 基于時間輪方式實現(xiàn)的定時器 時間復雜度最小，效率最高，然而我們可以通過 優(yōu)先隊列 實現(xiàn)時間輪定時器。
優(yōu)先隊列的實現(xiàn)可以使用最大堆和最小堆，因此在隊列中所有的數(shù)據(jù)都可以定義排序規(guī)則自動排序。我們直接通過隊列中 pop 函數(shù)獲取數(shù)據(jù)，就是我們按照自定義排序規(guī)則想要的數(shù)據(jù)。
在 Golang 中實現(xiàn)一個優(yōu)先隊列異常簡單，在 container/head 包中已經(jīng)幫我們封裝了，實現(xiàn)的細節(jié)，我們只需要實現(xiàn)特定的接口就可以。
下面是官方提供的例子
因為優(yōu)先隊列底層數(shù)據(jù)結構是由二叉樹構建的，所以我們可以通過數(shù)組來保存二叉樹上的每一個節(jié)點。
改數(shù)組需要實現(xiàn) Go 預先定義的接口 Len , Less , Swap , Push , Pop 和 update 。
timerType結構是定時任務抽象結構
首先的 start 函數(shù)，當創(chuàng)建一個 TimeingWheel 時，通過一個 goroutine 來執(zhí)行 start ,在start中for循環(huán)和select來監(jiān)控不同的channel的狀態(tài)
通過for循環(huán)從隊列中取數(shù)據(jù)，直到該隊列為空或者是遇見第一個當前時間比任務開始時間大的任務， append 到 expired 中。因為優(yōu)先隊列中是根據(jù) expiration 來排序的，
所以當取到第一個定時任務未到的任務時，表示該定時任務以后的任務都未到時間。
當 getExpired 函數(shù)取出隊列中要執(zhí)行的任務時，當有的定時任務需要不斷執(zhí)行，所以就需要判斷是否該定時任務需要重新放回優(yōu)先隊列中。 isRepeat 是通過判斷任務中 interval 是否大于 0 判斷，
如果大于0 則，表示永久就生效。
防止外部濫用，阻塞定時器協(xié)程，框架又一次封裝了timer這個包，名為 timer_wapper 這個包,它提供了兩種調(diào)用方式。
參數(shù)和上面的參數(shù)一樣，只是在第三個參數(shù)中使用了任務池，將定時任務放入了任務池中。定時任務的本身執(zhí)行就是一個 put 操作。
至于put以后，那就是 workers 這個包管理的了。在 worker 包中， 也就是維護了一個任務池，任務池中的任務會有序的執(zhí)行，方便管理。
swoole 服務層代碼怎么寫
swoole-1.7.7 發(fā)布，內(nèi)置Http服務器性能是Node.js的12倍
PHP的異步并發(fā)擴展swoole發(fā)布了 1.7.7 版本，此版本主要有：
增加對cygwin環(huán)境的支持
增加單次定時器的after接口
onClose事件調(diào)整為在close前觸發(fā)
增加內(nèi)置Http服務器
修復目前已知的所有BUG
單次定時器
swoole之前的版本僅支持間隔時間的固定定時器，1.7.7新增了單次定時器接口，可以指定在當前時間之后的n毫秒內(nèi)執(zhí)行一段代碼。
?
1
2
3
swoole_timer_after(500, function(){
echo "Hello Swoole\n";
}); //500ms
在服務器端程序中可以調(diào)用swoole_server對象的after方法。
?
1
2
3
4
5
$server-on('receive', function($server, $fd, $from_id, $data(){
$server-after(2000, function(){
echo "timeout\n";
});
}));
內(nèi)置Http服務器
在此版本中swoole內(nèi)部集成了一個Http服務器，由底層的C代碼解析Http協(xié)議。得益于swoole的多線程Reactor+多進程模型，swoole內(nèi)置Http服務器的性能非常好。通過使用apache bench工具進行壓測，性能是node.js的12倍，php-fpm的6倍，Go語言內(nèi)置的Http服務器的1.42倍。
壓測方法：
?
1
ab -c 200 -n 200000 -k
硬件環(huán)境：
?
1
Inter Core I5 3.2G * 4核 + 8G內(nèi)存
標題名稱：go語言定時器間隔執(zhí)行,golang 定時執(zhí)行
分享鏈接：http://m.jiaotiyi.com/article/hogcjs.html