Golang -- 使用 Bufferd channel 实现 线程安全的 pool

前端之家收集整理的这篇文章主要介绍了Golang -- 使用 Bufferd channel 实现 线程安全的 pool前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

文章 进行转载,再次感谢

概述

我们知道,Go 语言已经提供了 sync.Pool,但是做的不怎么好,所以有必要来实现一个 Pool

代码

type Pool struct {
    pool chan *Client
}

// Create a new Pool
func NewPool(max int) *Pool{
    return &Pool{
        pool: make(chan *Client,max)
    }
}

// Get a Client from Pool
func (p *Pool) Borrow() *Client {
    var cl *Client
    select {
    case cl = <-p.pool:
    default:
        c1 = newClient()
    }
    return cl
}

// Return the Cliet to the pool
func (p *Pool) Return(cl *Client){
    select {
    case p.pool<- cl:
    default:
        // let it go,let it go....
    }
}

现在是 Golang1.4了,sync.Pool还是不可以用吗?

原文链接:https://www.f2er.com/go/190464.html

猜你在找的Go相关文章