本篇文章為大家展示了tunny中workerWrapper的作用是什么，內容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

成都創(chuàng)新互聯(lián)成都網站建設按需設計，是成都網站制作公司,為成都地磅秤提供網站建設服務,有成熟的網站定制合作流程，提供網站定制設計服務：原型圖制作、網站創(chuàng)意設計、前端HTML5制作、后臺程序開發(fā)等。成都網站制作熱線：18982081108

workerWrapper

type workerWrapper struct {
	worker        Worker
	interruptChan chan struct{}

	// reqChan is NOT owned by this type, it is used to send requests for work.
	reqChan chan<- workRequest

	// closeChan can be closed in order to cleanly shutdown this worker.
	closeChan chan struct{}

	// closedChan is closed by the run() goroutine when it exits.
	closedChan chan struct{}
}

func newWorkerWrapper(
	reqChan chan<- workRequest,
	worker Worker,
) *workerWrapper {
	w := workerWrapper{
		worker:        worker,
		interruptChan: make(chan struct{}),
		reqChan:       reqChan,
		closeChan:     make(chan struct{}),
		closedChan:    make(chan struct{}),
	}

	go w.run()

	return &w
}

workerWrapper包裝了worker，定義了interruptChan、reqChan、closeChan、closedChan屬性

interrupt

func (w *workerWrapper) interrupt() {
	close(w.interruptChan)
	w.worker.Interrupt()
}

interrupt方法關閉w.interruptChan，執(zhí)行w.worker.Interrupt()

run

func (w *workerWrapper) run() {
	jobChan, retChan := make(chan interface{}), make(chan interface{})
	defer func() {
		w.worker.Terminate()
		close(retChan)
		close(w.closedChan)
	}()

	for {
		// NOTE: Blocking here will prevent the worker from closing down.
		w.worker.BlockUntilReady()
		select {
		case w.reqChan <- workRequest{
			jobChan:       jobChan,
			retChan:       retChan,
			interruptFunc: w.interrupt,
		}:
			select {
			case payload := <-jobChan:
				result := w.worker.Process(payload)
				select {
				case retChan <- result:
				case <-w.interruptChan:
					w.interruptChan = make(chan struct{})
				}
			case _, _ = <-w.interruptChan:
				w.interruptChan = make(chan struct{})
			}
		case <-w.closeChan:
			return
		}
	}
}

run首先創(chuàng)建jobChan、retChan，然后for循環(huán)執(zhí)行select讀取reqChan，之后讀取jobChan的payload，進行處理，然后寫入到retChan

stop

func (w *workerWrapper) stop() {
	close(w.closeChan)
}

stop方法關閉w.closeChan

join

func (w *workerWrapper) join() {
	<-w.closedChan
}

join方法則等待w.closedChan

小結

tunny的workerWrapper包裝了worker，定義了interruptChan、reqChan、closeChan、closedChan屬性，它提供了interrupt、run、stop、join方法。

上述內容就是tunny中workerWrapper的作用是什么，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網頁題目：tunny中workerWrapper的作用是什么
標題路徑：http://vcdvsql.cn/article4/podpoe.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供App設計、服務器托管、用戶體驗、外貿建站、App開發(fā)、小程序開發(fā)

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)