腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

综合排序丨最热优先丨最新优先

结构化并发

本篇提议引入 Swift 中对结构化并发的支持，使用提高工效、可预测并允许高效实现的模型，来实现异步代码的并发执行。 结构化并发任何并发系统必须提供基础工具。必须有某种方法创建与现有线程并发运行的新线程，也必须有某种方法让线程等待另一个线程发出继续的信号。这都是很强大的工具，你可以用它们来写非常复杂的系统。但是这是个临时的解决方案，而且需要在每个想使用并发的函数内重复使用。 结构化并发通过要求程序员组织他们的并发用法到高级任务和及其子组件任务里来解决上述问题。提议的解决方案我们提议的解决方案遵循上述结构化并发规则。所有异步函数都做为异步任务的一部分运行。任务可以产生并发执行的子任务。这确保结构化并发的结构得到维护，而且这不仅可以更容易去推断在给定的作用域内正在执行的并发任务，而且也为编译器和运行时提供了更多的优化机会。

2022-01-20

3.8K0

标签:

基于虚拟线程的结构化并发

在本文中，我们将讨论并发系统的一些新模式，这些模式是由 Java 21 中的新虚拟线程、结构化并发 (JEP 453 )和范围值(JEP 446： Scoped Values)组成的新的结构化并发模式。 结构化并发 (JEP 453 )和范围值(JEP 446)这两个新 API 中的第一个称为“结构化并发”。 结构化并发相比之下，结构化并发是为任务并行问题而设计的，其中涉及需要并行处理的不同但相关的子任务。API 与虚拟线程的密切关系意味着它主要适用于涉及一定量 I/O 的任务（尤其是对远程服务的调用）。 结构化并发任务的一般流程如下所示：创建任务作用域范围——创建线程拥有该范围（上下文）。在作用域内分叉并发子任务（每个子任务都是一个虚拟线程）。范围值/作用域值Scoped Values 除了结构化并发（Structured Concurrency）之外，新的范围值 API（Scoped Values API）也作为预览版出现在 Java 21

2023-11-07

7500

标签:

WorkIt结构化并发与任务取消机制

模式是一样的：分散的并发原语，没有共享的所有权。当兄弟任务抛出异常、超时触发、用户点击停止时，你必须自己拼接队列状态、重试延迟、超时包装器、底层 I/O、清理和错误形状。 C 执行 deferPromise.anyt=61 毫秒+47 毫秒 (总计 108 毫秒)不适用run.anyt=65 毫秒0 毫秒 (在 t=65 毫秒取消)是run.pool —— 可取消的有界并发但它不是一个结构化作用域：它不会自动将兄弟失败转化为进行中的取消、类型化的取消原因、清理和部分结果契约。run.pool(8, tasks) 是一个信号量 + 一个作用域。基准测试 04-pool-vs-semaphore.mjs：10 个项目，并发数 4。项目 3 在 20 毫秒时抛出；其余每个需要 100 毫秒。 WorkIt 的区别更窄：在保持 async/await 的同时进行结构化并发组合，在一个所有权树中提供九个可组合组件，以及上面显示的打包大小。

2026-05-18

1200

标签:

Go语言中有没有结构化并发？

本文原文地址在本博主博客，点击链接前往：Go语言中有没有结构化并发？图片什么是结构化并发？今天这篇文章要介绍的是结构化并发，就是为解决并发编程中线程并发任务管理，传统的方式非常容易造成管理混乱。 结构化并发设计在上面我介绍了一些关于非结构化并发的程序设计问题，如果单独创建协程没有做好错误处理或者异常情况下的处理，可能就会出现协程泄露问题，这就是本节要讲的结构化并发来做的并发控制设计。小结我个人认为结构化并发是未来的并发和并行程序设计方向，现在有结构化并发程序设计的语言Kotlin、Java、Swift等，Rust语言中也有这方面相关第三方实现目前还不够完善。解决并发编程之痛的良药：Rust结构化并发编程Go 中的分段栈和连续栈的区别？CPU眼里的：goto；因为强大，所以消失！译】「结构化并发」简析或：有害的go语句

一大块芝士

2022-09-15

1K0

标签:

JDK 21中的结构化并发：并发编程的一次飞跃

这个最初的预览特性来源于一个孵化 API，它根据前两轮的孵化纳入了一些改进，这两轮孵化分别是 JDK 19 交付的 JEP 428，结构化并发（孵化）和 JDK 20 交付的 JEP 437，结构化并发 JDK 21 中的结构化并发致力于引入结构化并发的 API 来简化并发编程。这种方法将在不同线程中运行的相关任务组视为一个工作单元，从而简化了错误处理和取消，提高了可靠性，并增强了可观测性。 结构化并发是一个预览 API，默认是禁用的。它的目的也不是为 Java 平台定义明确的结构化并发 API，或在线程间共享数据流的方法。这些模型不会强制要求或跟踪任务和子任务之间的关系，使得并发任务的管理和可观测性很具挑战性。 结构化并发提出，任务结构应该反映代码结构。

深度学习与Python

2023-08-09

8420

标签:

结构化并发才是王道!

我们直接运行代码看结果：我们先看一段结构化并发的Demo代码：获取用户信息任务为（执行3秒）：此时运行代码，应该两个子任务都不会抛异常，所以都能正常的执行，得到的结果为：如果把ShutdownOnFailure StructuredTask就执行结束了，所以获取用户信息任务就不会执行了（只执行了开头，相当于任务中止了），输出结果为：从中可以看出，ShutdownOnFailure和ShutdownOnSuccess就是结构化并发的精髓，那为什么叫结构化并发呢？我个人的理解是通过结构化并发，可以将多个并发子任务组合成一个大任务，并且这个大任务可以控制子任务的执行进度，就算子任务已经开始执行了也可以被中止。好了，你是怎么理解结构化并发的呢？说说你的理解。

程序员蜗牛

2024-03-07

1930

标签:

Go 结构化并发：给 goroutine 装上“安全带“

先讲个生活故事：放风筝vs开团队想象你在组织一次团队活动：❌无结构化并发（Go原生go）展开代码语言：TXTAI代码解释你：大家分头去采购！ ✅结构化并发展开代码语言：TXTAI代码解释你：大家分头采购，30分钟后门口集合，谁有问题随时喊我！A/B/C：收到！这就是StructuredConcurrency（结构化并发）要解决的问题。什么是结构化并发？为什么Go不内置结构化并发？ Go结构化并发最佳实践✅原则：每个goroutine都要有"主人"和"退出条件"展开代码语言：GoAI代码解释funcprocessItems(ctxcontext.Context,items[]string

GoLang学习记

2026-03-13

2070

标签:

JEP 428：结构化并发，简化 Java 多线程编程

作者 | A N M Bazlur Rahman 译者 | 明知山策划 | 丁晓昀 JEP 428，即结构化并发 (孵化器阶段)，已经从 Proposed 状态进入到 Target 状态。所以，它们是非结构化的并发代码。通过观察非结构化并发代码存在的这些问题，Martin Sústrik 在他的博文中创造了“结构化并发”这个术语，然后 Nathaniel J. Smith 在他关于结构化并发的文章中推广了这个术语。关于结构化并发，Oracle 技术咨询成员、Loom 项目负责人 Ron Pressler 在 InfoQ 的一个播客中说道： 结构化的意思是，如果你生成了什么东西，你必须等待并连接它。这里的“结构”与它在结构化编程中的含义相似。代码的块结构反映了程序的运行时行为。因此，就像结构化编程提供了顺序控制流保证，结构化并发也为并发提供了同样的保证。

深度学习与Python

2023-03-29

7890

标签:

聊聊 Java 21 中的结构化并发（预览版）

非结构化并发在开始了解结构化并发前，我们先回顾一下 Java 中非结构化并发的写法。 结构化并发在单线程编程模型中，编程语言通过代码块避免控制流随意跳转，从而实现程序的结构化。但在多线程编程（并发编程）模型中，线程之间控制和归属关系仍然存在很多问题，其面临的问题与 GOTO 的问题非常相似，这也是结构化并发所要解决的问题。什么是结构化并发呢？下面是非结构化并发（图一）和结构化并发（图二）的运行示例图：Java 结构化并发示例public class Test { public static void main(String[] args 提高并发代码的可观察性。以下不是目前非结构化并发的目标不会替换现有的任务并发结构。

2023-11-08

8930

标签:

2023腾讯·技术创作特训营第三期

从任务到线程：Java结构化并发应用程序

并发设计的本质，就是要把程序的逻辑分解为多个任务，这些任务独立而又协作的完成程序的功能。而其中最关键的地方就是如何将逻辑上的任务分配到实际的线程中去执行。在线程中执行任务并发程序设计的第一步就是要划分任务的边界，理想情况下就是所有的任务都独立的:每个任务都是不依赖于其他任务的状态，结果和边界。因为独立的任务是最有利于并发设计的。 while (true) { final Socket connection = socket.accept(); //为每个请求创建单独的线程任务，保证并发性使得主线程不用等待任务完毕就可以去快速地去响应下一个请求，以达到高响应速度；任务处理可以并行，支持同时处理多个请求；任务处理是线程安全的，因为每个任务都是独立的不过需要注意的是，任务必须是线程安全的，否者多线程并发时会有问题既然是并发处理，当然会遇到一次性提交一组任务的情况，这个时候可以使用CompletionService，CompletionService可以理解为Executor和BlockingQueue的组合：当一组任务被提交后

2018-12-07

8690

标签: