标签： 原语

发布于

什么是‘响应式原语’（Reactive Primitives）？对比 Signal、Observable 与 Proxy 的设计哲学

技术讲座：响应式原语（Reactive Primitives） 引言 在当今的软件开发领域，响应式编程已经成为了一种重要的编程范式。它允许开发者构建更加灵活、可扩展和易于维护的软件系统。响应式编程的核心概念之一就是响应式原语，它指的是那些能够处理异步数据流的原语。本文将深入探讨响应式原语的概念，并对比Signal、Observable与Proxy这三种设计哲学。 响应式原语 响应式原语是指那些能够处理异步数据流的原语。它们通常用于实现事件驱动、异步编程和实时数据流等功能。响应式原语的核心思想是“观察者模式”，即当一个数据源发生变化时，所有订阅了该数据源的观察者都会得到通知。 Signal Signal是一种响应式原语，它起源于Qt框架。Signal是一种对象，它能够发送通知，当它的状态发生变化时。Signal通常与Slot一起使用，Slot是接收Signal通知的函数。 class Person: def __init__(self, name): self.name = name def set_name(self, name): self.name = name self.name …

继续阅读“什么是‘响应式原语’（Reactive Primitives）？对比 Signal、Observable 与 Proxy 的设计哲学”

发布于

利用 SharedArrayBuffer 与 Futex 原语：在 JavaScript 中实现无锁（Lock-free）并发哈希表

大家好，欢迎来到本次技术讲座。今天我们将深入探讨一个令人兴奋且极具挑战性的话题：在 JavaScript 中构建一个无锁（Lock-free）并发哈希表。我们将利用现代 Web 平台提供的强大原语——SharedArrayBuffer 和 Futex——来实现这一目标。 在多核处理器日益普及的今天，前端应用也开始面临传统后端领域才有的并发编程挑战。Web Workers 允许我们将计算密集型任务卸载到后台线程，避免阻塞主线程。然而，当这些 Workers 需要共享和修改同一份数据时，问题就来了。传统的做法是使用消息传递，但这通常涉及到数据的序列化和反序列化，效率低下。更高级的解决方案是共享内存，但共享内存带来了数据竞争的风险。 这就是无锁编程的用武之地。通过避免传统的互斥锁（mutexes），我们可以消除死锁的风险，提高在高并发下的吞吐量和响应速度。当然，无锁编程的实现难度也相应增加。 1. 并发编程的基石：SharedArrayBuffer 与 Atomics 要实现无锁数据结构，我们首先需要两个核心工具：SharedArrayBuffer 和 Atomics 对象。 1.1 Sha …

继续阅读“利用 SharedArrayBuffer 与 Futex 原语：在 JavaScript 中实现无锁（Lock-free）并发哈希表”

发布于

C++实现进程间的同步原语：利用操作系统信号量（Semaphore）与互斥体（Mutex）

C++ 进程间同步：信号量与互斥体 大家好，今天我们来深入探讨 C++ 中进程间同步的两种重要原语：信号量（Semaphore）和互斥体（Mutex）。在多进程并发编程中，这两个工具至关重要，它们能够确保多个进程在访问共享资源时的正确性和一致性，避免出现数据竞争和其他并发问题。 1. 进程间同步的必要性 在单进程环境下，线程间的同步机制已经可以解决大部分并发问题。但是，当程序涉及到多个独立的进程协同工作时，线程间的同步机制就无法直接应用。这是因为： 地址空间隔离: 每个进程都有自己独立的地址空间，线程共享同一个地址空间，因此线程间同步可以直接通过共享内存来实现。而进程间不能直接访问彼此的内存。 资源竞争: 多个进程可能需要访问同一个文件、网络端口、硬件设备或其他系统资源，如果没有适当的同步机制，就会导致资源竞争。 因此，我们需要进程间同步机制，允许进程以可控的方式共享资源和进行通信。 2. 信号量（Semaphore） 信号量是一种计数器，用于控制多个进程对共享资源的访问。它维护一个整数值，表示可用资源的数量。进程可以通过 wait (或 acquire, P操作) 操作来减少信号量的 …

继续阅读“C++实现进程间的同步原语：利用操作系统信号量（Semaphore）与互斥体（Mutex）”

发布于

C++ OpenMP实现任务、数据与循环并行化：调度策略与同步原语的底层机制

C++ OpenMP实现任务、数据与循环并行化：调度策略与同步原语的底层机制 各位同学，大家好！今天我们深入探讨C++ OpenMP中任务并行、数据并行和循环并行化，并详细分析其调度策略和同步原语的底层机制。OpenMP (Open Multi-Processing) 是一个应用程序编程接口 (API)，支持共享内存多处理系统上的并行编程。它由一组编译器指令、库例程和环境变量组成，允许开发者轻松地将串行程序转换为并行程序。 1. OpenMP 概述与基本概念 OpenMP基于fork-join模型。程序开始时以单个线程（主线程）执行。当遇到并行区域时，主线程fork出一组线程，形成一个线程组。线程组中的所有线程并行执行并行区域内的代码。并行区域执行完毕后，所有线程join回主线程，程序继续以单线程方式执行。 核心概念： 并行区域 (Parallel Region): 程序中需要并行执行的代码块。使用#pragma omp parallel指令定义。 线程 (Thread): 执行代码的独立实体。 线程组 (Team): 由主线程fork出的一组线程。 工作共享构造 (Work-Shar …

继续阅读“C++ OpenMP实现任务、数据与循环并行化：调度策略与同步原语的底层机制”

发布于

Asyncio中的同步原语（Lock, Semaphore, Event）：在非阻塞环境下的实现机制

Asyncio 同步原语：非阻塞环境下的实现机制 大家好！今天我们来深入探讨 asyncio 库中的同步原语，包括 Lock、Semaphore 和 Event，重点分析它们在非阻塞环境下的实现机制。在传统的并发编程中，我们依赖线程和锁来保证共享资源的安全访问。但在 asyncio 的单线程事件循环模型下，直接使用线程锁会导致阻塞，破坏异步并发的特性。因此，asyncio 提供了一套专门设计的同步原语，它们基于协程和 future 实现，能够在不阻塞事件循环的情况下进行同步操作。 1. 为什么需要同步原语？ 在 asyncio 中，多个协程并发执行，共享相同的事件循环和内存空间。如果没有适当的同步机制，多个协程同时访问和修改共享资源可能会导致数据竞争和不一致性。例如，考虑一个简单的计数器： import asyncio counter = 0 async def increment(): global counter for _ in range(10000): counter += 1 async def main(): await asyncio.gather(increment( …

继续阅读“Asyncio中的同步原语（Lock, Semaphore, Event）：在非阻塞环境下的实现机制”

发布于

C++ 发布-订阅模式：基于并发原语实现高效事件系统

各位观众，各位朋友，欢迎来到今天的“C++并发原语与高效发布-订阅模式”讲座！今天咱们不搞虚的，直接上干货，用C++并发原语给你撸一个高性能的事件系统，让你的代码跑得飞起，告别卡顿！ 啥是发布-订阅模式？ 在咱们开始造轮子之前，先简单聊聊“发布-订阅”模式。这就像你订阅了一个报纸，报社（发布者）一有新消息（事件），就会自动送到你的邮箱（订阅者）。简单来说： 发布者 (Publisher): 负责产生事件。 订阅者 (Subscriber): 负责接收特定类型的事件。 事件 (Event): 包含特定信息的对象。 消息队列/事件总线 (Message Queue/Event Bus): 连接发布者和订阅者的中间件。 好处嘛，那就是解耦！发布者和订阅者不需要知道彼此的存在，全靠事件总线这个“媒婆”牵线搭桥。 为啥要用并发原语？ 单线程的发布-订阅模式？那还不如用函数指针回调呢！我们追求的是高性能，充分利用多核CPU的优势。所以，并发原语是关键。我们要保证： 线程安全： 多个线程同时发布和订阅事件，数据不能乱。 高效： 尽可能减少锁的竞争，提高吞吐量。 并发原语选型： 并发原语 优点 缺点 …

继续阅读“C++ 发布-订阅模式：基于并发原语实现高效事件系统”