Go 编程实例【线程池 Worker Pool】

秒速五厘米 2023-10-08 21:48 31阅读 0赞

#### 阅读目录 ####

在这个例子中，我们将看到如何使用 Go 协程和通道实现一个线程池 。

// worker-pools.go
    package main
    
    import (
    	"fmt"
    	"time"
    )
    
    // 这里是 worker，我们将并发执行多个 worker。
    // worker 将从 `jobs` 通道接收任务，并且通过 `results` 发送对应的结果。
    // 我们将让每个任务间隔 1s 来模仿一个耗时的任务。
    func worker(id int, jobs <-chan int, results chan<- int) {
        
    	for j := range jobs {
        
    		fmt.Println("worker", id, "processing job", j)
    		time.Sleep(time.Second)
    		results <- j * 2
    	}
    }
    
    func main() {
        
    
    	// 为了使用 worker 线程池并且收集他们的结果，我们需要 2 个通道。
    	jobs := make(chan int, 100)
    	results := make(chan int, 100)
    
    	// 这里启动了 3 个 worker，初始是阻塞的，因为还没有传递任务。
    	for w := 1; w <= 3; w++ {
        
    		go worker(w, jobs, results)
    	}
    
    	// 这里我们发送 9 个 `jobs`，然后 `close` 这些通道
    	// 来表示这些就是所有的任务了。
    	for j := 1; j <= 9; j++ {
        
    		jobs <- j
    	}
    	close(jobs)
    
    	// 最后，我们收集所有这些任务的返回值。
    	for a := 1; a <= 9; a++ {
        
    		<-results
    	}
    }

[root@bogon test]# go run worker-pools.go
    worker 3 processing job 1
    worker 1 processing job 2
    worker 2 processing job 3
    worker 2 processing job 4
    worker 3 processing job 5
    worker 1 processing job 6
    worker 1 processing job 7
    worker 2 processing job 8
    worker 3 processing job 9
    [root@bogon test]#

发表评论取消回复

表情：

评论列表（有 0 条评论，31人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java 线程池(Thread Pools)详解

目录 1、线程池介绍 2、线程池执行原理 3、线程池中的阻塞队列 4、Java 线程池中的拒绝策略 5、Java 提供的创建线程池的方式 6、线程池的使用示例 7

秒速五厘米/ 2024年03月22日 14:19/ 0 赞/ 76 阅读

相关深入浅出Java线程池Worker类

文章目录 1 重要参数 1.1 七个构造参数 1.2 重要成员变量 2 提交任务 3 工

Love The Way You Lie/ 2023年10月08日 22:52/ 0 赞/ 22 阅读

相关 Go 编程实例【线程池 Worker Pool】

阅读目录在这个例子中，我们将看到如何使用 Go 协程和通道实现一个线程池。 // worker-pools.go package main

秒速五厘米/ 2023年10月08日 21:48/ 0 赞/ 32 阅读

相关线程池精讲（pthread pool）

线程池也是多线程的处理方式。是将“生产者”线程提出任务添加到“任务队列”，然后一些线程自动完成“任务队列”上的任务。多线程编程，

青旅半醒/ 2022年12月10日 10:29/ 0 赞/ 191 阅读

相关 go协程池（goroutine）、go线程池（Thread）、go连接池

一、go协程池（goroutine） `注意`： `Go`语言中的`goroutine`虽然相对于系统线程来说比较轻量级（初始栈大小仅`2KB`），但是在高并发量下的`

Dear 丶/ 2022年11月02日 01:00/ 0 赞/ 588 阅读

相关 Go实现线程池

本文通过代码讲解如何实现一个线程池。代码及注释如下： <table> <tbody> <tr> <td> <div> 1

谁践踏了优雅/ 2022年09月26日 02:19/ 0 赞/ 179 阅读

相关 Android Thread Pool(线程池)

众所周知，显式创建，开启线程的方式： new Thread( new RunnableTask（） ).start()；这种方式，每次调用都会产生对象（java

深藏阁楼爱情的钟/ 2022年09月24日 13:25/ 0 赞/ 222 阅读

相关 Thread Pool(线程池)技术

Thread Pool(线程池)技术技术背景介绍在面向对象编程中，创建和销毁对象是很费时间的，因为创建一个对象要获取内存资源或者其它更多资源。

Love The Way You Lie/ 2022年09月21日 05:35/ 0 赞/ 218 阅读

相关 36 多线程之线程池pool

在面向对象编程中，创建和销毁对象是很费时间的，因为创建一个对象要获取内存资源或其他更多资源。虚拟机也将试图跟踪每一个对象，以便能够在对象销毁后进行垃圾回收。同样的道理，多任务情

以你之姓@/ 2022年09月06日 00:17/ 0 赞/ 30 阅读

相关线程池 Thread Pools

线程池原文地址：[jenkov][] 作者： Jakob Jenkov 译者：[长源][Link 1] 校对：方腾飞线程池（Thread Pool）对于限制应

小咪咪/ 2022年08月25日 15:48/ 0 赞/ 121 阅读