当前位置: 首页 > article >正文

说说软件工程中的“协程”

在软件工程中,协程(coroutine)是一种程序运行的方式,可以理解成“协作的线程”或“协作的函数”。以下是对协程的详细解释:

一、协程的基本概念

  1. 定义:协程是一组序列化的子过程,用户能像指挥家一样调度交叉执行。协程既可以用单线程实现,也可以用多线程实现,但无论如何,其核心特点是能够并行执行且可以交换执行权
  2. 执行方式:在协程中,多个线程(或函数)可以并行执行,但只有一个线程(或函数)处于正在运行的状态,其他线程(或函数)都处于暂停态(suspended)。线程(或函数)之间可以交换执行权,即一个线程(或函数)执行到一半时,可以暂停执行,将执行权交给另一个线程(或函数),等到稍后收回执行权时,再恢复执行。

二、协程的特性

  1. 可控制性:协程能做到可被控制的发起子任务,这是与线程相比的一个重要区别。
  2. 轻量级:协程非常小、占用资源比线程还少。在JVM平台上,协程的本质就是一次方法的调用。
  3. 状态保留:协程能保留上一次调用时的状态(即所有局部状态的一个特定组合),每次过程重入时,就相当于进入上一次调用的状态。
  4. 用户级线程:协程不像线程和进程那样,需要进行系统内核上的上下文切换。协程的上下文切换是由开发人员决定的,因此更加高效。

三、协程的应用场景

  1. 网络编程:使用协程可以使网络编程更加简洁和高效,例如实现高性能的服务器程序。
  2. 并发编程:协程可以简化并发编程,提高代码的可读性和可维护性,减少并发编程的复杂性。
  3. 异步编程:协程可以简化异步编程,避免回调地狱和多线程的问题,提高代码的可读性和可维护性。
  4. 资源管理:协程可以更好地管理资源,避免资源泄露和内存泄漏的问题。
  5. 任务调度:协程可以用于实现轻量级的任务调度器,实现任务的调度和执行。
  6. 状态机:协程可以用于实现复杂的状态机,简化状态机的实现和维护。
  7. 数据处理:协程可以用于处理大量的数据,提高数据处理的效率和性能。

四、协程与线程、进程的对比

  1. 线程:线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中,是进程中的实际运作单位。线程切换需要操作系统内核的支持,因此开销较大。
  2. 进程:进程是操作系统分配资源的最小单位,它包含一组执行中的程序的指令、还有程序所使用到的数据和引用到的系统资源(如文件、内存等)。进程切换同样需要操作系统内核的支持,开销同样较大。
  3. 协程:协程是一种用户级的轻量级线程,它的上下文切换是由开发人员决定的,不需要操作系统内核的支持,因此开销较小。这使得协程在并发编程和异步编程中具有更高的效率和更好的可维护性。

综上所述,协程是一种高效的程序运行方式,在软件工程领域具有广泛的应用前景。

五,当前能直接实现协程的开发语言

 直接支持协程的开发语言包括但不限于以下几种:

  1. Golang(Go)
    • Go语言从设计之初就内置了对协程的支持,通过轻量级的goroutine实现。
    • Goroutine是Go语言中的一种并发体,它比线程更轻量,由Go运行时管理。
    • Go语言的协程特性使其在系统编程、高性能计算和云计算领域具有显著优势。
  2. Kotlin
    • Kotlin是一种在JVM上运行的静态类型编程语言,它支持协程作为一等公民。
    • Kotlin协程提供了一种在保持代码简洁性的同时实现高效并发的方法。
    • Kotlin协程特别适用于Android开发,以及需要在JVM上运行的其他应用程序。
  3. C#
    • C#是Microsoft开发的一种多范式编程语言,自某个版本开始引入了异步编程模式,包括async和await关键字,这些关键字可以视为协程的一种实现方式。
    • C#的协程特性使其特别适用于需要处理大量IO操作或需要高效并发处理的应用程序。
      using System;
      using System.Threading.Tasks;
      
      class Program
      {
          static async Task AsyncTask(int step, int delay)
          {
              await Task.Delay(delay); // 模拟异步操作
              Console.WriteLine($"Step: {step}");
          }
      
          static async Task CoroutineLikeExample()
          {
              for (int i = 0; i < 5; i++)
              {
                  await AsyncTask(i + 1, 1000); // 等待异步任务完成
              }
              Console.WriteLine("All steps completed.");
          }
      
          static void Main(string[] args)
          {
              CoroutineLikeExample().Wait(); // 等待异步方法完成(在Main方法中需要这样做,因为Main不能是异步的)
          }
      }

  4. Python
    • Python通过其内置的asyncio库支持异步编程,这可以看作是一种协程的实现方式。
    • 虽然Python的asyncio库不是传统意义上的协程,但它提供了一种编写异步代码的方法,使代码更加简洁和易于维护。
    • Python的协程特性在数据科学、机器学习、Web开发和自动化脚本等领域具有广泛应用。
  5. JavaScript
    • JavaScript通过其内置的async/await语法和Promise对象支持异步编程,这也可以看作是一种协程的实现方式(尽管在严格意义上它可能不是传统意义上的协程)。
    • JavaScript的协程特性使其在Web开发、全栈开发和实时应用等领域具有广泛应用。
  6. C++(C++20及以后)
    • C++20标准引入了协程支持,通过co_await、co_yield和co_return等关键字实现。
    • C++的协程特性使其在系统编程、高性能计算和实时系统等领域具有显著优势。 
#include <iostream>
#include <coroutine>
#include <memory>
#include <thread>
#include <chrono>

// 定义协程的返回类型和promise类型
struct MyTask {
    struct promise_type;
    using handle_type = std::coroutine_handle<promise_type>;

    struct promise_type {
        MyTask get_return_object() {
            return MyTask{handle_type::from_promise(*this)};
        }
        std::suspend_always initial_suspend() { return {}; }
        std::suspend_always final_suspend() noexcept { return {}; }
        void return_void() {}
        void unhandled_exception() { std::exit(1); }
    };

    handle_type coro;

    MyTask(handle_type h) : coro(h) {}
    ~MyTask() { if (coro) coro.destroy(); }

    void resume() {
        if (coro.done()) return;
        coro.resume();
        // 注意:在实际应用中,你可能需要在这里添加循环或条件检查来避免忙等待
    }
};

MyTask myCoroutine() {
    for (int i = 0; i < 6; ++i) {
        std::cout << "Step: " << i << std::endl;
        std::this_thread::sleep_for(std::chrono::seconds(1)); // 休眠1秒
        co_await std::suspend_always{}; // 暂停协程
    }
}

int main() {
    auto task = myCoroutine();

    // 模拟事件循环或任务调度器
    for (int i = 0; i < 6; ++i) {
        task.resume(); // 恢复协程的执行
        std::this_thread::sleep_for(std::chrono::milliseconds(10)); // 简单的延迟,避免忙等待
    }

    return 0;
}


http://www.kler.cn/a/397734.html

相关文章:

  • 营销手段的变革:开源 AI 智能名片与 S2B2C 商城小程序在新趋势下的机遇与挑战
  • 【Hadoop实训】Hive 数据操作②
  • 单元测试、集成测试、系统测试、验收测试、压力测试、性能测试、安全性测试、兼容性测试、回归测试(超详细的分类介绍及教学)
  • 电商系统开发:Spring Boot框架实战
  • Java21和Java8性能优化详细对比
  • Python调用API翻译Excel中的英语句子并回填数据
  • FFMPEG录像推流时遇到的问题
  • 【ArcGIS微课1000例】0128:ArcGIS制作规划图卫星影像地图虚化效果
  • 2024山西省网络建设运维第十八届职业院校技能大赛解析答案(2. DNS 服务)
  • C++(Qt)软件调试---无法校验pdb时间戳(23)
  • Ubuntu从入门到精通(一)系统安装
  • 使用 Ant Design Vue 自定渲染函数customRender实现单元格合并功能rowSpan
  • css-50 Projects in 50 Days(3)
  • 屏幕拾色器
  • GESP4级考试语法知识(贪心算法(四))
  • 从二维到一维:动态规划矩阵问题的优化之道
  • spring-cache concurrentHashMap 自定义过期时间
  • 将 HTML 转换为 JSX:JSX 和 JSX 规则
  • 【项目开发】分析六种常用软件架构
  • ISCTF2024
  • 算法沉淀一:双指针
  • 【Android Compose原创组件】可拖动滚动条的完美实现
  • 算法:快排(三指针算法)
  • YashanDB 23.2.3安装过程,并使用DBeaver进行连接
  • 【如何获取股票数据47】Python、Java等多种主流语言实例演示获取股票行情api接口之沪深指数历史分时KDJ数据获取实例演示及接口API说明文档
  • windows C#-创建记录类型(下)