Skip to content

Latest commit

 

History

History
54 lines (31 loc) · 1.52 KB

README.md

File metadata and controls

54 lines (31 loc) · 1.52 KB

执行流程

1.主线程执行

  1. 创建发送端和接受端
  2. 发送端调用spawn方法,将async块封装成Task发送到channel中
  3. 接受端while循环revc方法,每次会循环会阻塞,直到接受到Task
  4. 取出task中的future,Poll一次
  5. 第一次poll后,async块开始执行

image-20230923180704360

2.async块执行

  1. async块执行如图,new 一个TimerFuture
  2. new方法返回之前开启了一个新的线程
  3. new方法返回TimerFuture如图第二个黄框,然后poll一下
  4. 发现poll返回Pending,就会放回future到Task(task放)。
  5. 第二次循环开始,revc阻塞

image-20230923181103380

3.async块开启新线程

  1. Sleep(2)代表代码执行需要cost一些时间
  2. 完成后TimerFuture中的一些field update完成
    • 这里能更新是因为Arc<Mutex>,共享内存,一起修改
  3. 新线程结束时调用wake方法

4.新线程唤起主线程

下面的都在第三个图

  1. Task的wake方法发送一个新的Task到channel中
  2. 主线程的Receiver接受到Task,开始第二轮执行

async块执行结束

此时在主线程执行

  1. 第二轮poll发现新线程更新了completed为true,所以结束返回Ready
  2. 此时async块执行结束

5.主线程执行结束

  1. run方法发现ready了,那么task就不会放回,channel关闭,run方法结束

image-20230923184050586