gopool

README

go线程池使用方法

package main

import (
	"fmt"
	"github.com/orestonce/gopool"
)

func main() {
	task := gopool.NewThreadPool(10) // 最大线程数
	task.AddJob(func() {
		fmt.Println("thread1")
	})
	task.AddJob(func() {
		fmt.Println("thread2")
	})
	task.CloseAndWait()
}

Documentation

Index

• type ThreadPool
  • func NewThreadPool(maxSize int) *ThreadPool
  • func (this *ThreadPool) AddJob(fn func())
  • func (this *ThreadPool) CloseAndWait()

Types

type ThreadPool

type ThreadPool struct {
	// contains filtered or unexported fields
}

func NewThreadPool

func NewThreadPool(maxSize int) *ThreadPool

func (*ThreadPool) AddJob

func (this *ThreadPool) AddJob(fn func())

func (*ThreadPool) CloseAndWait

func (this *ThreadPool) CloseAndWait()