接收完成 发送完成 接收完成 无缓冲通道 所有通道：开始发送 → 接收完成（同一个数据）； - 对于无缓冲channel：开始接收 → 发送完成（同一个数据）； 其他的对于init函数，锁，协程，原子操作，sync包里的功能，还有许多保证，更详细可以看：https://golang.org/ref/mem https://go101.org/article/memory-model.html [Image](/uploads/documents/d/8/3/8/d8388e030498b4a865900850a6f7e74b/p17_1.jpg) ## 消除数据竞争 可用的happens : • 互斥锁/读写锁 • 原子操作 • 通道 • Sync包中的其他能力(sync.Map, sync.WaitGroup, sync.Cond, sync.Once) • golang.org/x/sync中的能力(errgroup sendq waitq lock mutex 而channel和map底层虽然也是结构体，使用者实际使用的是其指针，其自身的读写只需考虑指针的数据竞争 ## 消除数据竞争的误区：锁保护的是谁？ ## ● ● ● type item struct { data int } var m = make(map[string]*item) var lock sync

访问临界资源的那段代码就是临界区，临界区必须互斥地使用。 ## 互斥锁 Java 引入对象互斥锁机制来实现线程的互斥操作，保证共享数据操作的完整性。 Java 中每个对象都有一个互斥锁与之相连，用来保证在任一时刻，只能有一个线程访问该对象。 多线程对临界资源的并发访问是通过竞争互斥锁实现的。 ## synchronized 的用法 为了保证互斥，Java 语言使用synchronized关键字标识同步的资源，包括： } // Other code } ## synchronized 的功能 首先判断对象或者方法的互斥锁是或否存在，若存在就获得互斥锁，然后执行紧随其后的临界代码段或方法体； 如果对象或方法的互斥锁不在（已经被其他线程拿走），就进入线程等待状态，直到获得互斥锁。 课程配套代码 ▶ sample.thread.syn.WithdrawMoneyFromBankSample.java 上），该线程暂停执行而进入对象 x 的等待队列，并释放已获得的对象 x 的互斥锁。线程 A 要一直等到其他线程在对象 x 上调用 notify() 或 notifyAll() 方法，才能重新获得对象 x 的互斥锁后继续执行（从 wait() 语句后继续执行）。 notify() 唤醒正在等待该对象互斥锁的第一个线程。 notifyAll() 唤醒正在等待该对象互斥锁的所有线程，具有最高优先级的线程首先被唤醒并执行。 ##

- 联机事务处理 ## 出色的OLTP特性 ## 天生的优势 行式存储 索引 ● 直接分发 ● 完整的增删改 ## Greenplum 6 增强 ● 并发修改、删除 系统性的优化事务和锁 ## 行式存储 ■ 更适合OLTP负载 ☑ 高效更改和删除 适合需要全部或者多数列的查询 ## 表 orders ## Pivotal ## 索引 ## The B-Tree Bitmap _detector' -v on ## Pivotal ## Greenplum 6: 锁和事务的优化 大幅减少事务开始和结束时的锁冲突 ☑ 消除隐式只读操作(单条SELECT)的锁冲突 避免显式只读事务(BEGIN-SELECT-END)的两阶段提交（开发中） fastpath锁(PostgreSQL合并) ## TPC-B基准测试:环境 基于谷歌云平台(Google Cloud 879fc523a03552b8058583920607820/p49_1.jpg) ## 展望 ### Greenplum 6.x/7 PostgreSQL合并:BRIN索引和并行扫描 ■ 锁和事务的优化 磁盘IO的资源管理 更多思路？ ## 资源 中文社区: http://greenplum.cn 文档: https://qpdb.docs.pivotal.io/6-0Beta/main/index

. 59 总结 ..... 60 习题 ..... 60 进一步阅读的参考资料 ..... 62 第7章并行与并发 ..... 63 7.1 并行基础 ..... 63 7.2 互斥量与临界区 …… 63 7.3 期物 …… 65 7.4 条件变量 …… 66 7.5 原子操作与内存模型 …… 68 原子操作 …… 69 一致性模型 …… 70 return 0; } ### 7.2 互斥量与临界区 我们在操作系统、亦或是数据库的相关知识中已经了解过了有关并发技术的基本知识，mutex 就是其中的核心之一。C++11 引入了 mutex 相关的类，其所有相关的函数都放在 头文件中。 std::mutex 是 C++11 中最基本的 mutex 类，通过实例化 std::mutex 可以创建互斥量，而通过其成员函数 lock() ，因为调用成员函数就需要在每个临界区的出口处调用 unlock()，当然，还包括异常。这时候 C++11 还为互斥量提供了一个 RAII 语法的模板类 std::lock_guard。RAII 在不失代码简洁性的同时，很好地保证了代码的异常安全性。 在 RAII 用法下，对于临界区的互斥量的创建只需要在作用域的开始部分，例如： #include #include

，使得交易处理性能达到万级以上。 • 基于C++的Precompiled合约：区块链底层内置C++语言编写的Precompiled合约，执行效率更高。 - 交易并行执行：基于DAG算法根据交易间互斥关系构建区块内交易执行流，最大化并行执行区块内的交易。 • 交易生命周期的异步并行处理：共识、同步、落盘等各个环节的异步化以及并行处理。 ### 1.5 安全性 考虑到联盟链的高安全性需求，除 1.0版本以及大部分业界传统区块链平台，交易是被打包成一个区块，在一个区块中交易顺序串行执行的。2.0版本基于预编译合约，实现一套并行交易处理模型，基于这个模型可以自定义交易互斥变量。在区块执行过程中，系统将会根据交易互斥变量自动构建交易依赖关系图——DAG，基于DAG并行执行交易，最好情况下性能可提升数倍（取决于CPU核数）。 更多并行计算模型的介绍，请参考并行交易的设计文档和使用手册。 #### PBFTBackup的存储由LevelDB修改为RocksDB • 重构libdevcrypto模块，优化代码结构，使用TASSL实现国密和非国密TLS连接 • 优化存储模块openTable的锁实现 • 优化区块数据编码为并行 • 优化大对象析构耗时为异步 • 优化日志输出机制，降低日志输出对性能的影响 - 优化MHD和交易池模块的线程数，减少内存占用 • 优化MySQL存储适配器

(stop - start)) if __name__ == '__main__': main() ★多进程同步之 lock（互斥锁） 使用 multiprocessing.Lock() 方法创建一个互斥锁， 互斥锁在同一时刻只允许一个线程访问共享数据 使用多进程时，各进程拥有独立的内存空间，无法共享内存空间，所以各进程无法访问同一个全局变量，若需要各进程共享某个全局变量，可以使用 for i in range(10): lock.acquire() print("进程{}已获取锁".format(multiprocessing.current_process().name)) # 获取锁，用于线程同步 n = random.randint(0, 5) shared_var.value += format(multiprocessing.current_process().name, shared_var.value)) lock.release() # 释放锁，开启下一个线程 print("进程{}释放锁".format(multiprocessing.current_process().name)) def main(): process_list

，使得交易处理性能达到万级以上。 - 基于C++的Precompiled合约：区块链底层内置C++语言编写的Precompiled合约，执行效率更高。 - 交易并行执行：基于DAG算法根据交易间互斥关系构建区块内交易执行流，最大化并行执行区块内的交易。 • 交易生命周期的异步并行处理：共识、同步、落盘等各个环节的异步化以及并行处理。 ### 1.5 安全性 考虑到联盟链的高安全性需求，除 1.0版本以及大部分业界传统区块链平台，交易是被打包成一个区块，在一个区块中交易顺序串行执行的。2.0版本基于预编译合约，实现一套并行交易处理模型，基于这个模型可以自定义交易互斥变量。在区块执行过程中，系统将会根据交易互斥变量自动构建交易依赖关系图——DAG，基于DAG并行执行交易，最好情况下性能可提升数倍（取决于CPU核数）。 更多并行计算模型的介绍，请参考并行交易的设计文档和使用手册。 #### PBFTBackup的存储由LevelDB修改为RocksDB - 重构libdevcrypto模块，优化代码结构，使用TASSL实现国密和非国密TLS连接 • 优化存储模块openTable的锁实现 • 优化区块数据编码为并行 · 优化大对象析构耗时为异步 - 优化日志输出机制，降低日志输出对性能的影响 • 优化MHD和交易池模块的线程数，减少内存占用 • 优化MySQL存储适配器实现，优化ZdbStorage的代码实现

，使得交易处理性能达到万级以上。 • 基于C++的Precompiled合约：区块链底层内置C++语言编写的Precompiled合约，执行效率更高。 - 交易并行执行：基于DAG算法根据交易间互斥关系构建区块内交易执行流，最大化并行执行区块内的交易。 • 交易生命周期的异步并行处理：共识、同步、落盘等各个环节的异步化以及并行处理。 ### 1.5 安全性 考虑到联盟链的高安全性需求，除 1.0版本以及大部分业界传统区块链平台，交易是被打包成一个区块，在一个区块中交易顺序串行执行的。2.0版本基于预编译合约，实现一套并行交易处理模型，基于这个模型可以自定义交易互斥变量。在区块执行过程中，系统将会根据交易互斥变量自动构建交易依赖关系图——DAG，基于DAG并行执行交易，最好情况下性能可提升数倍（取决于CPU核数）。 更多并行计算模型的介绍，请参考并行交易的设计文档和使用手册。 #### PBFTBackup的存储由LevelDB修改为RocksDB - 重构libdevcrypto模块，优化代码结构，使用TASSL实现国密和非国密TLS连接 • 优化存储模块openTable的锁实现 • 优化区块数据编码为并行 · 优化大对象析构耗时为异步 - 优化日志输出机制，降低日志输出对性能的影响 • 优化MHD和交易池模块的线程数，减少内存占用 • 优化MySQL存储适配器

，使得交易处理性能达到万级以上。 • 基于C++的Precompiled合约：区块链底层内置C++语言编写的Precompiled合约，执行效率更高。 - 交易并行执行：基于DAG算法根据交易间互斥关系构建区块内交易执行流，最大化并行执行区块内的交易。 • 交易生命周期的异步并行处理：共识、同步、落盘等各个环节的异步化以及并行处理。 ### 1.5 安全性 考虑到联盟链的高安全性需求，除 1.0版本以及大部分业界传统区块链平台，交易是被打包成一个区块，在一个区块中交易顺序串行执行的。2.0版本基于预编译合约，实现一套并行交易处理模型，基于这个模型可以自定义交易互斥变量。在区块执行过程中，系统将会根据交易互斥变量自动构建交易依赖关系图——DAG，基于DAG并行执行交易，最好情况下性能可提升数倍（取决于CPU核数）。 更多并行计算模型的介绍，请参考并行交易的设计文档和使用手册。 #### PBFTBackup的存储由LevelDB修改为RocksDB - 重构libdevcrypto模块，优化代码结构，使用TASSL实现国密和非国密TLS连接 • 优化存储模块openTable的锁实现 • 优化区块数据编码为并行 · 优化大对象析构耗时为异步 - 优化日志输出机制，降低日志输出对性能的影响 • 优化MHD和交易池模块的线程数，减少内存占用 • 优化MySQL存储适配器