golang如何利用多核


当前第2页 返回上一页

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

package mainimport (

        "runtime"

        "fmt"

        "sync"

        "database/sql"

        _ "github.com/go-sql-driver/mysql"

    "time")//定义任务队列var waitgroup sync.WaitGroupfunc xtgxiso(num int) {

        //fmt.Println(num)

        db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test?charset=utf8")

        if err != nil {

                fmt.Println(err)

        }

        defer db.Close()

        rows, err := db.Query("select sleep(1) as a")

        if err != nil {

                fmt.Println(err)

        }

        defer rows.Close()

        var a string

        for rows.Next() {

                err = rows.Scan(&a)

                if err != nil {

                        fmt.Println(err)

                } else {

                        //fmt.Println(a)

                }

        }

        waitgroup.Done() //任务完成,将任务队列中的任务数量-1,其实.Done就是.Add(-1)}func main() {

    //记录开始时间

    start := time.Now()

        //设置最大的可同时使用的CPU核数和实际cpu核数一致

        runtime.GOMAXPROCS(1)

        for i := 1; i <= 10; i++ {

                waitgroup.Add(1) //每创建一个goroutine,就把任务队列中任务的数量+1

                go xtgxiso(i)

        }

        waitgroup.Wait() //Wait()这里会发生阻塞,直到队列中所有的任务结束就会解除阻塞

    //记录结束时间

    end :=  time.Now()

    //输出执行时间,单位为秒。

    fmt.Println(end.Sub(start).Seconds())}

这个程序是执行十次”select sleep(1) as a“.如果是顺序阻塞执行的话,执行时间肯定是10s以上,而我们用的协程不会有这种情况。我们可以修改“runtime.GOMAXPROCS(1)”来设置是单核还是多核心执行。

更多golang知识请关注golang教程栏目。

以上就是golang如何利用多核的详细内容,更多文章请关注木庄网络博客!!

返回前面的内容

相关阅读 >>

golang 用olivere库操作elastic search

string,byte,rune

钉钉 chatops demo

go高级进阶:goroutine的创建、休眠与恢复

go并发处理

go语言入门-1 环境搭建

洗牌算法的golang实现,随便学习几个知识点

golang如何设置字体

手撸golang 基本数据结构与算法 归并排序

以大见小 - rust快速实践(一)

更多相关阅读请进入《golang》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...