多核编程4种方式:多线程、多进程、csp(轻量级线程)、actor(轻量级进程)

2024-03-28 16:32

本文主要是介绍多核编程4种方式:多线程、多进程、csp(轻量级线程)、actor(轻量级进程),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1)多线程方式利用多核心
    锁(信号量、互斥锁、自旋锁、读写锁、原子锁cas、乐观锁、悲观锁)
        锁的粒度
        什么情况下用什么锁,比较困惑

    消息队列

    管道(不需要加锁): pipe+epoll/select/epoll

    资源+锁

    并发实体:线程

    总结:
        需要大量的锁。

2)多进程方式利用多核心
    共享内存

    pipe管道、
        父进程fork子进程有限制
        只能一端读一端写
        数据是单向的

    socket:
        一般用这种来
        用epoll

    信号

    并发实体:进程。

    总结:


3)csp模型
    go语言:
        并发实体:goroutine(协程,用channel来通信)。
        协程是轻量级的线程。
        协程切换比较轻量,是开发者自己调度的。
        线程切换需要进程,进程切换需要。

    总结:
        优化多线程的编程方式。

4)actor
    erlang: 
        语言层面实现actor模型。
        把actor命名为进程,actor是轻量级的进程。

    skynet:
        从框架层面实现actor。


    actor由程序来调度,比较轻量。

    提几个问题:
        1.actor之间是如何沟通的?
            统一性差,隔离性强。
            独立的运行环境。
            a actor和b actor沟通,就发送到对方的消息队列中。
                多进程是socket沟通,其实也是消息的方式。

        2.actor是怎么运行的?
            多进程中,有一个主线程,通过os调度来运行。
            actor中,当消息队列中有消息的时候,就可以运行:
                多个线程,消耗actor消息。 工作线程。轮训,消息队列取出消息,并在actor
                    环境中运行了。
                取出消息,并且调用回调函数。

        3.actor是如何调度的呢?
            不是每个actor都有消息。这个怎么处理呢?
                全局消息队列。把actor中的消息插入全局消息队列,指针的方式。
                通过多线程消费全局消息队列的方式来调度actor,这样范围缩小,效率提高。

                将有消息的消息队列放入全局消息队列中,工作线程只需要轮训全局消息队列,
                    就可以对整个actor消息进行调度了。

        4.actor怎么接收网络中的数据?
            fd和actor绑定

            epoll_create
                红黑树+就绪队列
            epoll_ctrl
                epoll_event, fd, actor_id 
            epoll_wait(ev[])
                取出一个数组
                ev[].data.ptr -->actorid, fd--》找到actor--》网络线程发送数据到actor

        5.如何使用skynet?
            agent--》玩家actor
            hall--》大厅actor
            main--》启动actor
            redis---》玩家不能退出,重新进去要保存数据。 redis actor
            room--》房间actor,3人一个房间组成的actor

            ./skynet/skynet config.test
                main
                redis
                hall


            把功能拆分成多个actor, 热点拆分为多个actor,
                 一个actor就是一个统一性较差的环境。

            架构:
                main:网关--》listenfd
                agent: connedfd--》其它数据全部由agent进行处理
                    游戏是相同的,我们不能放到一个actor中处理,而要创建很多个节点,充分利用cpu
                    每一个client都有一个agent
                hall:保存匹配队列的--》大厅
                    每一个agent与hall连接
                    hall去创建一个room actor


                skynet中的2种调用方式:    
                    send:消息队列send,异步调用。
                    call--》rpc: 阻塞,同步调用。

            指导思想: 简单可用,逐步优化,忌讳过度优化


            逻辑的完备性
                

            actor:
                隔离的环境(lua或内存块)
                回调函数
                消息队列

            单线程来处理的        

            让工作线程去轮训只有消息的actor

    总结:
        优化的是多进程的解决方案。
        

---------------------------
并发编程的2个考虑:

    隔离性
        运行环境隔离:
            多线程隔离性差、统一性高

    统一性
        数据的统一


------------------------------
分布式:
    C:一致性
    A:可用性
    P:分区容错性


----------------------
源码:
    nginx
    redis
    skynet
    zeromq

造轮子:
    中间件:
        内存池
        线程池
        连接池
        消息队列

    高并发IO:
        epoll
        reactor
        proactor

    网络协议栈:
        用户态,实现百万连接

    nginx模块开发

    并发设计

    集群能力:
        数据库的集群。
        zookeeper的集群--》多进程的管理。

    linux内核编程:
        网卡子系统的编程
        内存管理
        进程间通信
        内核的编译

    性能测试:
        数据库的索引优化和sql优化。
        linux调优、内存调优。

    部署能力:
        docker


    一线架构

这篇关于多核编程4种方式:多线程、多进程、csp(轻量级线程)、actor(轻量级进程)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/856120

相关文章

Linux线程同步/互斥过程详解

《Linux线程同步/互斥过程详解》文章讲解多线程并发访问导致竞态条件,需通过互斥锁、原子操作和条件变量实现线程安全与同步,分析死锁条件及避免方法,并介绍RAII封装技术提升资源管理效率... 目录01. 资源共享问题1.1 多线程并发访问1.2 临界区与临界资源1.3 锁的引入02. 多线程案例2.1 为

shell脚本批量导出redis key-value方式

《shell脚本批量导出rediskey-value方式》为避免keys全量扫描导致Redis卡顿,可先通过dump.rdb备份文件在本地恢复,再使用scan命令渐进导出key-value,通过CN... 目录1 背景2 详细步骤2.1 本地docker启动Redis2.2 shell批量导出脚本3 附录总

Oracle查询表结构建表语句索引等方式

《Oracle查询表结构建表语句索引等方式》使用USER_TAB_COLUMNS查询表结构可避免系统隐藏字段(如LISTUSER的CLOB与VARCHAR2同名字段),这些字段可能为dbms_lob.... 目录oracle查询表结构建表语句索引1.用“USER_TAB_COLUMNS”查询表结构2.用“a

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Oracle数据库定时备份脚本方式(Linux)

《Oracle数据库定时备份脚本方式(Linux)》文章介绍Oracle数据库自动备份方案,包含主机备份传输与备机解压导入流程,强调需提前全量删除原库数据避免报错,并需配置无密传输、定时任务及验证脚本... 目录说明主机脚本备机上自动导库脚本整个自动备份oracle数据库的过程(建议全程用root用户)总结

Debian系和Redhat系防火墙配置方式

《Debian系和Redhat系防火墙配置方式》文章对比了Debian系UFW和Redhat系Firewalld防火墙的安装、启用禁用、端口管理、规则查看及注意事项,强调SSH端口需开放、规则持久化,... 目录Debian系UFW防火墙1. 安装2. 启用与禁用3. 基本命令4. 注意事项5. 示例配置R

最新Spring Security的基于内存用户认证方式

《最新SpringSecurity的基于内存用户认证方式》本文讲解SpringSecurity内存认证配置,适用于开发、测试等场景,通过代码创建用户及权限管理,支持密码加密,虽简单但不持久化,生产环... 目录1. 前言2. 因何选择内存认证?3. 基础配置实战❶ 创建Spring Security配置文件

Python获取浏览器Cookies的四种方式小结

《Python获取浏览器Cookies的四种方式小结》在进行Web应用程序测试和开发时,获取浏览器Cookies是一项重要任务,本文我们介绍四种用Python获取浏览器Cookies的方式,具有一定的... 目录什么是 Cookie?1.使用Selenium库获取浏览器Cookies2.使用浏览器开发者工具

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释:举个例子:✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多

Java获取当前时间String类型和Date类型方式

《Java获取当前时间String类型和Date类型方式》:本文主要介绍Java获取当前时间String类型和Date类型方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录Java获取当前时间String和Date类型String类型和Date类型输出结果总结Java获取