多核编程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

相关文章

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》:本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq

HTTP 与 SpringBoot 参数提交与接收协议方式

《HTTP与SpringBoot参数提交与接收协议方式》HTTP参数提交方式包括URL查询、表单、JSON/XML、路径变量、头部、Cookie、GraphQL、WebSocket和SSE,依据... 目录HTTP 协议支持多种参数提交方式,主要取决于请求方法(Method)和内容类型(Content-Ty

Java中如何正确的停掉线程

《Java中如何正确的停掉线程》Java通过interrupt()通知线程停止而非强制,确保线程自主处理中断,避免数据损坏,线程池的shutdown()等待任务完成,shutdownNow()强制中断... 目录为什么不强制停止为什么 Java 不提供强制停止线程的能力呢?如何用interrupt停止线程s

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

python 线程池顺序执行的方法实现

《python线程池顺序执行的方法实现》在Python中,线程池默认是并发执行任务的,但若需要实现任务的顺序执行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋... 目录方案一:强制单线程(伪顺序执行)方案二:按提交顺序获取结果方案三:任务间依赖控制方案四:队列顺序消

Spring创建Bean的八种主要方式详解

《Spring创建Bean的八种主要方式详解》Spring(尤其是SpringBoot)提供了多种方式来让容器创建和管理Bean,@Component、@Configuration+@Bean、@En... 目录引言一、Spring 创建 Bean 的 8 种主要方式1. @Component 及其衍生注解

Python异步编程之await与asyncio基本用法详解

《Python异步编程之await与asyncio基本用法详解》在Python中,await和asyncio是异步编程的核心工具,用于高效处理I/O密集型任务(如网络请求、文件读写、数据库操作等),接... 目录一、核心概念二、使用场景三、基本用法1. 定义协程2. 运行协程3. 并发执行多个任务四、关键

python中的显式声明类型参数使用方式

《python中的显式声明类型参数使用方式》文章探讨了Python3.10+版本中类型注解的使用,指出FastAPI官方示例强调显式声明参数类型,通过|操作符替代Union/Optional,可提升代... 目录背景python函数显式声明的类型汇总基本类型集合类型Optional and Union(py