介绍
Flink的Task是通过线程实现的。在Flink中，每个并行的任务都会被分配给一个线程来执行。Flink的任务执行引擎会根据任务的并行度来创建对应数量的线程，并将不同的任务分配到这些线程上进行执行。
每个Flink任务都包含一个或多个子任务（也称为子任务链），并且每个子任务都分配给一个线程来执行。当一个子任务完成时，它的输出数据将被传递给下一个子任务，这些子任务可以在同一个线程或不同的线程上执行。由于Flink的任务执行引擎是基于线程池的，因此可以避免为每个子任务创建新线程的开销，从而提高任务执行的效率。
除了任务执行线程之外，Flink还使用了一些其他类型的线程，如调度线程、心跳线程、网络I/O线程等，这些线程可以协同工作来实现任务的高效执行。

源码示例