Go帶緩沖的延時發(fā)送功能

為了提升發(fā)送時的吞吐量,本文采用類似Nagle算法的發(fā)送方式:

  1. 數(shù)據(jù)先存入發(fā)送緩沖區(qū)
  2. 若緩沖區(qū)已滿,則立即發(fā)送
  3. 若緩沖區(qū)未滿态罪,則等待指定時間發(fā)送
package main

import (
    "fmt"
    "sync"
    "time"
)

type Message struct {
    ch      chan int
    buf     []int
    size    int
    timeout <-chan time.Time
    once    sync.Once
}

func newMessage(size int) *Message {
    return &Message{
        ch:      make(chan int, size),
        buf:     make([]int, 0, size),
        size:    size,
        timeout: time.After(1 * time.Second),
    }
}

/**
 * 此方法僅執(zhí)行一次黎茎,所以不需要加鎖
 */
func (m *Message) Send() {
    m.once.Do(func() {
        fmt.Println("once")
        for {
            select {
            case d := <-m.ch:
                m.buf = append(m.buf, d)
                if len(m.buf) >= m.size {
                    fmt.Println("full buffer, send data...", m.buf)
                    m.buf = m.buf[:0]
                }
            case <-m.timeout:
                if len(m.buf) > 0 {
                    fmt.Println("timeout and send data...", m.buf)
                    m.buf = m.buf[:0]
                }

                m.timeout = time.After(1 * time.Second)

            }
        }
    })

}

func (m *Message) Receive(val int) {
    fmt.Println("receive data:", val)
    m.ch <- val
    time.Sleep(time.Second)

}

func main() {
    msg := newMessage(100)
    go msg.Send()
    for i := 0; i < 100; i++ {
        go msg.Receive(i)
    }

    time.Sleep(5 * time.Minute)
}


最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市炉峰,隨后出現(xiàn)的幾起案子畏妖,更是在濱河造成了極大的恐慌,老刑警劉巖疼阔,帶你破解...
    沈念sama閱讀 212,686評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件瓜客,死亡現(xiàn)場離奇詭異,居然都是意外死亡竿开,警方通過查閱死者的電腦和手機(jī)谱仪,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,668評論 3 385
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來否彩,“玉大人疯攒,你說我怎么就攤上這事×欣螅” “怎么了敬尺?”我有些...
    開封第一講書人閱讀 158,160評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長贴浙。 經(jīng)常有香客問我砂吞,道長,這世上最難降的妖魔是什么崎溃? 我笑而不...
    開封第一講書人閱讀 56,736評論 1 284
  • 正文 為了忘掉前任蜻直,我火速辦了婚禮,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘概而。我一直安慰自己呼巷,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 65,847評論 6 386
  • 文/花漫 我一把揭開白布赎瑰。 她就那樣靜靜地躺著王悍,像睡著了一般。 火紅的嫁衣襯著肌膚如雪餐曼。 梳的紋絲不亂的頭發(fā)上压储,一...
    開封第一講書人閱讀 50,043評論 1 291
  • 那天,我揣著相機(jī)與錄音源譬,去河邊找鬼渠脉。 笑死,一個胖子當(dāng)著我的面吹牛瓶佳,可吹牛的內(nèi)容都是我干的芋膘。 我是一名探鬼主播,決...
    沈念sama閱讀 39,129評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼霸饲,長吁一口氣:“原來是場噩夢啊……” “哼为朋!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起厚脉,我...
    開封第一講書人閱讀 37,872評論 0 268
  • 序言:老撾萬榮一對情侶失蹤习寸,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后傻工,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體霞溪,經(jīng)...
    沈念sama閱讀 44,318評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,645評論 2 327
  • 正文 我和宋清朗相戀三年中捆,在試婚紗的時候發(fā)現(xiàn)自己被綠了鸯匹。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,777評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡泄伪,死狀恐怖殴蓬,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情蟋滴,我是刑警寧澤染厅,帶...
    沈念sama閱讀 34,470評論 4 333
  • 正文 年R本政府宣布,位于F島的核電站津函,受9級特大地震影響肖粮,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜尔苦,卻給世界環(huán)境...
    茶點故事閱讀 40,126評論 3 317
  • 文/蒙蒙 一涩馆、第九天 我趴在偏房一處隱蔽的房頂上張望行施。 院中可真熱鬧,春花似錦凌净、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,861評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至皿渗,卻和暖如春斩芭,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背乐疆。 一陣腳步聲響...
    開封第一講書人閱讀 32,095評論 1 267
  • 我被黑心中介騙來泰國打工划乖, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人挤土。 一個月前我還...
    沈念sama閱讀 46,589評論 2 362
  • 正文 我出身青樓琴庵,卻偏偏與公主長得像,于是被迫代替她去往敵國和親仰美。 傳聞我的和親對象是個殘疾皇子迷殿,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,687評論 2 351

推薦閱讀更多精彩內(nèi)容