Kafka概述 Kafka是一个基于发布、订阅的分布式消息队列,用于大数据实时处理。 为什么要用kafka? 注册信息的过程,先在网站上填写注册信息,后台会调用其他服务的接口,反馈给网页注册成功信息,最后再显示给用户,并且将短信发送给用户,该过程为同步通信过程,需要同步等待，由于同步通信的过程比较慢 ...
分类：
其他好文 时间：
2021-06-02 12:12:15
阅读次数：
0
Go语言中除了可以使用通道（channel）和互斥锁进行两个并发程序间的同步外，还可以使用等待组进行多个任务的同步，等待组可以保证在并发环境中完成指定数量的任务 在 sync.WaitGroup（等待组）类型中，每个 sync.WaitGroup 值在内部维护着一个计数，此计数的初始默认值为零。 等 ...
分类：
其他好文 时间：
2020-08-04 09:48:34
阅读次数：
65
###文章结构 源码：对doReleaseShared()方法的源码进行一些注释 使用场景：介绍doReleaseShared()使用位置，及目的 以写锁开始的队列：分析写锁开始得同步等待队列在唤醒后续读锁节点的过程 以读锁开始的队列 总结 ###源码 具体解析见注释 /** * Release a ...
分类：
其他好文 时间：
2020-06-03 15:54:25
阅读次数：
123
图中可以很清晰的看见执行的顺序 改变了p1的执行位置以后。。。 可以发现在同步任务中的状态被改变了，从处理变成了准备状态。 也就是我们前面赋值过程其实是一个同步等待的过程，等待微任务p1的执行完成后才执行的赋值。 ...
分类：
Web程序 时间：
2020-03-15 22:36:52
阅读次数：
262
1. 临界资源 package main import ( "fmt" "time" ) func main() { /* 临界资源： */ a := 1 go func() { a = 2 fmt.Println("goroutine中。。",a) }() a = 3 time.Sleep(1) ...
分类：
其他好文 时间：
2020-02-03 09:57:08
阅读次数：
89
处理收到的Stanzas 背部 Smack使用两种结构提供了一个灵活的框架来处理传入的节： org.jivesoftware.smack.StanzaCollector - 一个允许您同步等待新节的类。 org.jivesoftware.smack.StanzaListener - 用于异步通知您传 ...
分类：
其他好文 时间：
2019-08-27 19:20:30
阅读次数：
136
第三部分：内核区同步 等待函数(WaitForObject) 等待函数的形式 单个：WaitForSingleObject 多个：WaitForMultipleObjects 单个：WaitForSingleObject 多个：WaitForMultipleObjects 一个可以被等待的对象通常由 ...
多线程爬虫 多线程的复杂性 1.资源、数据的安全性：锁保护 2.原子性：数据操作是天然互斥的 3.同步等待：wait（）、notify（）、notifyAll（） 4.死锁：多个线程对资源互锁，造成死锁 5.容灾：任何线程出现错误，整个进程都会停止 多线程的优势 1.内存空间共享，信息数据交换效率高 ...
分类：
编程语言 时间：
2019-03-13 12:41:24
阅读次数：
185
一、问题描述本来是想测试一下svn的post-commit hook为什么能够实现对于后台任务的同步等待，所以就搭建了一个apache和svn的服务器程序，但是在调试的过程中一直出现文件系统打不开的问题，在apache的错误日志中也可以看到下面的提示内容， 1647 [Sun Oct 14 11:4 ...
分类：
Web程序 时间：
2019-03-07 10:22:14
阅读次数：
1321
1.Ajax与jsonp（1）ajax技术的目的是让JavaScript发送HTTP请求，与后台通信，获取数据和信息。Ajax技术的原理是实例化xmlhttp对象，使用此对象与后台通信。Ajax通信的过程不会影响后续JavaScript的执行，从而实现异步。（2）同步和异步同步：等待结果返回在执行异步：不管结果继续执行（3）局部刷新和无刷新Ajax可以实现局部刷新，也叫无刷新，无刷新指的是整个页面
分类：
Web程序 时间：
2019-01-13 18:03:24
阅读次数：
224
