func thriftPoolFactory() (*pool.ThriftPoolClient, error) {
	addr := "127.0.0.1"
	clientChan := make(chan *pool.ThriftPoolClient)
	errChan := make(chan error)

	go func(addr string) {
		protocolFactory := thrift.NewTBinaryProtocolFactory(true, true)
		transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())

		socket, err := thrift.NewTSocket(addr)
		if err != nil {
			errChan <- err
		}
		if socket == nil {
			errChan <- fmt.Errorf("Error opening socket, got nil transport")
		}

		transport, err := transportFactory.GetTransport(socket)
		if err != nil {
			errChan <- fmt.Errorf("Error from transportFactory, got nil transport")
		}

		err = transport.Open()
		if err != nil {
			errChan <- err
		}

		clientChan <- &pool.ThriftPoolClient{TStandardClient: thrift.NewTStandardClient(protocolFactory.GetProtocol(transport), protocolFactory.GetProtocol(transport)), Conn: socket.Conn()}
	}(addr)

	select {
	case client := <-clientChan:
		return client, nil
	case err := <-errChan:
		return nil, err
	case <-time.After(time.Second * 3):
		return nil, fmt.Errorf("Timeout waiting for connection")
	}
}

clientPool, err := pool.NewThriftPool(10, 100, thriftPoolFactory)
if err != nil {
	return err
}

thriftClient, err := clientPool.Get()

thriftClient.Close()