bucket

README

go-bucket

Golang concurrent storage elements to the containers and return to a specified number of a single container

Usage

$ go get github.com/antlinker/go-bucket

Benchmark

Ran 100 samples:
  push:
    Fastest Time: 0.029s
    Slowest Time: 0.034s
    Average Time: 0.031s ± 0.001s
------------------------------

写入数据条数： 10000000
总耗时：3.09s

License

Copyright 2016.All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Documentation

Index

• type Bucket
  • func NewListBucket() Bucket
• type BucketGroup
  • func NewBucketGroup(popBucketElementCount int, bucketPoolsNum ...int) BucketGroup

Types

type Bucket

type Bucket interface {
	// Push Insert the elements to the bucket,return bucket length
	// If the exception occurs, it returns an error
	Push(v interface{}) (int, error)
	// Pop Pop an element
	// If the exception occurs, it returns an error
	Pop() (interface{}, error)
	// Len Get bucket length
	Len() int
	// ToSlice Get all the elements of the slice
	// If the exception occurs, it returns an error
	ToSlice() ([]interface{}, error)
	// Reset Empty bucket elements
	Reset()
	// Clone Get bucket duplicate
	Clone() Bucket
	// CloneAndReset Get bucket duplicate and empty elements
	CloneAndReset() Bucket
}

Bucket Concurrent storage container element

func NewListBucket

func NewListBucket() Bucket

NewListBucket Based on the list container implementation bucket

type BucketGroup

type BucketGroup interface {
	// Open Open the bucket group waits to receive bucket
	// If already open,it returns an error
	Open() (<-chan Bucket, error)
	// Push Insert the elements to the bucket group
	// If the exception occurs, it returns an error
	Push(v interface{}) error
	// Len Get current use bucket length
	Len() int
	// Close Close bucket group,stop receive data
	// If the exception occurs, it returns an error
	Close() error
}

BucketGroup Concurrent storage elements to the bucket group return to a specified number of a single bucket

func NewBucketGroup

func NewBucketGroup(popBucketElementCount int, bucketPoolsNum ...int) BucketGroup

NewBucketGroup Create instances of BucketGroup popBucketElementCount The number of pop-up bucket required elements bucketPoolsNum The number of buckets within the group