包含golangpush的詞條

本文目錄一覽：

• 1、go語言tcp協議push指令怎麼用
• 2、Golang-基於TimeingWheel定時器
• 3、golang 結構體 位元組對齊是怎麼樣的

go語言tcp協議push指令怎麼用

PUSH指令主要用於編寫子程序和中斷服務程序，可以臨時保存程序狀態字PSW和累加器ACC的內容 或其它寄存器和存儲器單元的內容。

在子程序和中斷服務程序結束返回主程序前，要用POP彈棧指令，從堆棧中取出被保護的數據，恢復程序狀態字PSW和累加器ACC的內容 或其它寄存器和存儲器單元的內容。

呵呵 滿意 就選滿意回答啊

Golang-基於TimeingWheel定時器

在linux下實現定時器主要有如下方式

在這當中 基於時間輪方式實現的定時器 時間複雜度最小，效率最高，然而我們可以通過 優先隊列 實現時間輪定時器。

優先隊列的實現可以使用最大堆和最小堆，因此在隊列中所有的數據都可以定義排序規則自動排序。我們直接通過隊列中 pop 函數獲取數據，就是我們按照自定義排序規則想要的數據。

在 Golang 中實現一個優先隊列異常簡單，在 container/head 包中已經幫我們封裝了，實現的細節，我們只需要實現特定的介面就可以。

下面是官方提供的例子

因為優先隊列底層數據結構是由二叉樹構建的，所以我們可以通過數組來保存二叉樹上的每一個節點。

改數組需要實現 Go 預先定義的介面 Len , Less , Swap , Push , Pop 和 update 。

timerType結構是定時任務抽象結構

首先的 start 函數，當創建一個 TimeingWheel 時，通過一個 goroutine 來執行 start ,在start中for循環和select來監控不同的channel的狀態

通過for循環從隊列中取數據，直到該隊列為空或者是遇見第一個當前時間比任務開始時間大的任務， append 到 expired 中。因為優先隊列中是根據 expiration 來排序的，

所以當取到第一個定時任務未到的任務時，表示該定時任務以後的任務都未到時間。

當 getExpired 函數取出隊列中要執行的任務時，當有的定時任務需要不斷執行，所以就需要判斷是否該定時任務需要重新放回優先隊列中。 isRepeat 是通過判斷任務中 interval 是否大於 0 判斷，

如果大於0 則，表示永久就生效。

防止外部濫用，阻塞定時器協程，框架又一次封裝了timer這個包，名為 timer_wapper 這個包,它提供了兩種調用方式。

參數和上面的參數一樣，只是在第三個參數中使用了任務池，將定時任務放入了任務池中。定時任務的本身執行就是一個 put 操作。

至於put以後，那就是 workers 這個包管理的了。在 worker 包中， 也就是維護了一個任務池，任務池中的任務會有序的執行，方便管理。

golang 結構體 位元組對齊是怎麼樣的

用golang解析二進位協議時，其實沒必要管結構體的欄位的對齊規則，何況語言規範也沒有規定如何對齊，也就是沒有規則。用encoding/binary.Read函數直接讀入struct里就行，struct就像c那樣寫

type Data struct {

Size, MsgType uint16

Sequence uint32

// …

}

golang編譯器加不加padding，Read都能正常工作，runtime知道Data的布局的，不像C直接做cast所以要知道怎樣對齊。

用unsafe.Alignof可以知道每個field的對齊長度，但沒必要用到。

package main

/*

#include stdint.h

#pragma pack(push, 1)

typedef struct {

uint16_t size;

uint16_t msgtype;

uint32_t sequnce;

uint8_t data1;

uint32_t data2;

uint16_t data3;

} mydata;

#pragma pack(pop)

mydata foo = {

1, 2, 3, 4, 5, 6,

};

int size() {

return sizeof(mydata);

}

*/

import “C”

import (

“bytes”

“encoding/binary”

“fmt”

“log”

“unsafe”

)

func main() {

bs := C.GoBytes(unsafe.Pointer(C.foo), C.size())

fmt.Printf(“len %d data %v\n”, len(bs), bs)

var data struct {

Size, Msytype uint16

Sequence uint32

Data1 uint8

Data2 uint32

Data3 uint16

}

err := binary.Read(bytes.NewReader(bs), binary.LittleEndian, data)

if err != nil {

log.Fatal(err)

}

fmt.Printf(“%v\n”, data) // {1 2 3 4 5 6}

buf := new(bytes.Buffer)

binary.Write(buf, binary.BigEndian, data)

fmt.Printf(“%d %v\n”, buf.Len(), buf.Bytes()) // 15 [0 1 0 2 0 0 0 3 4 0 0 0 5 0 6]

}