# goroutinepool

**Repository Path**: JxGolibs/goroutinepool

## Basic Information

- **Project Name**: goroutinepool
- **Description**: 一个简单的go golang 协程池
使用原生的channel和waitgroup实现，简单实用
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2022-02-03
- **Last Updated**: 2022-02-06

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# goroutinepool
Simple Goroutine pool  
一个简单的go golang 协程池  
使用原生的channel和waitgroup实现，简单实用

# How to use

```
go get gitee.com/JxGolibs/goroutinepool
```

## Simple example

```go

package main

import (
	"gitee.com/JxGolibs/goroutinepool"
	"time"
	"fmt"
)

func main() {

	p := goroutinepool.NewRoutinePool(10)
	for i := 0; i < 100; i++ {
		count := i
		p.AddJob(func() {
			time.Sleep(1000 * time.Millisecond)
			fmt.Printf("%d\n", count)
		})

	}
	p.Wait()
}

```

## Test Parallel Sum

```go

package main

import (
	"github.com/pkufergus/goroutinepool"
	"time"
	"fmt"
	"sync"
)

func main() {

	p := goroutinepool.NewRoutinePool(10)
	g_index := 0
	var lock *sync.Mutex
	lock = new(sync.Mutex)
	for i := 0; i < 100; i++ {
		count := i
		p.AddJob(func() {
			time.Sleep(1000 * time.Millisecond)
			fmt.Printf("%d\n", count)
			lock.Lock()
			defer lock.Unlock()
			g_index++
		})

	}
	p.WaitAll()
	fmt.Printf("sum=%d\n", g_index)
}

```

## Doc
详细的文档
https://blog.csdn.net/pkufergus/article/details/86495914

## 后续
1、增加参数传递  
2、增加返回参数传递  
3、增加超时控制  

 ## 问题相关

 有任何问题欢迎提Issue,或者将问题描述发送至我邮箱 `caosong1319@gmail.com`.我会尽快解答.推荐提交Issue方式.