一、map并发读写问题 如果map由多协程同时读和写就会出现 fatal error:concurrent map read and map write的错误 如下代码很容易就出现map并发读写问题 func main(){ c := make(map[string]int) go func() {//开一个协程写map for j := 0; j < 1000000; j++ { c[fmt.Sprintf("%d", j)] = j } }() go func() { //开一个协程读map for j := 0; j < 1000000; j++ { fmt.Println(c[fmt.Sprintf("%d",j)]) } }() time.Sleep(time.Second*20)...阅读全文
源码地址 https://github.com/slclub/goevents 概述 事件package。 我们可以自由灵活的使用事件，支持串行事件，并行事件； 且可以将串行事件 按定义的模块去触发. 事件函数的自定义参数无限制，但没有返回值。具体执行事件灵活自定义，用On 类函数接口注入到goevents。 可以灵活的绑定事件队列的参数。针对事件去绑定，或者，统一触发事件之前去绑定，或者混合着使用。单个绑定的优先级会更高一些 API English Doc 获取代码到本地 go get github.com/slclub/goevents 使用案例 串行化事件使用案例 ```go import "github.com/slclub/go...阅读全文
go-serial 是一个允许在Go中读取和写入串行端口的软件包。它利用Go进行串口通讯。 目前该软件包仅适用于 OS X，Linux 和 Windows，它可能只需更新一些常量就可以移植到其他类Unix平台上。 只需使用`go get`： 更新: 设置一个`serial.OpenOptions`结构，然后调用`serial.Open`。例如...阅读全文
见代码注释： package main import ( "fmt" "sync" ) func main() { sourceArray := [...]string{"a", "b", "c", "d", "e", "f", "g"} fmt.Println(sourceArray) slice_1 := sourceArray[:4] slice_2 := sourceArray[2:] slice_3 := sourceArray[1:] slice_4 := slice_3[1:] slice_5 := slice_4[1:] slice_1[3] = "i" fmt.Println(sourceArray) fmt.Println(slice_1) fmt.Println(sli...阅读全文
首先需要澄清一个事实：redis服务端是单线程处理客户端请求，也就是说客户端请求在服务端是串行化执行的，因此对服务端来说，并不存在并发问题。但业务方却存在并发操作redis中的同一个key的情况。所以如何让A客户端知道B客户端正在操作它想操作的 key，就成了必须要讨论的问题。 那么开始总结下方案吧： 1. SETNX key value //key存在就不做任何操作，返回0；不存在操作成功返回1 这种方式通过对需要操作的key加锁来保证并发操作的串行化。这里我们以Golang代码为例来举例说明该操作。先看多个协程写同一个key的情况。代码如下： package main import ( "fmt" "github.com/garyburd/redigo/redis" "runtime" ...阅读全文
我的环境如下： INTEL I5-2500K 4CORE 3.7GHZ 8G 内存 我分别用C#4.0和GO1.1写了一个计算质数的小程序。 C#我分别用串行算法和并行算法计算了1000,10000,50000,100000以内的质数。 GOLANG我只是用了并行算法，也是计算了1000,10000,50000,100000以内大的质数。 算法很简单，就是两个for循环。本以为GO是本地语言，至少要比C#快一些的。结果却让我吐血 GO: 目前有4个CPU 执行1000次的时间 4 毫秒 .............................. 执行10000次的时间 256 毫秒 ...................阅读全文
放在这里做个备份 package main import ( "fmt" "log" "net" ) const ( realServer = "127.0.0.1:9002" selfPort = 9010 ) type gameConn struct { ClientConn net.Conn PkgBuf [maxPkgSize]byte PkgLen int Channel chan int } var gbChannel chan int var connMap map[int](*gameConn) func main() { // Listen on TCP port 2000 on all interfaces. ip := net.ParseIP("0.0.0.0") ad...阅读全文
hyflow-go是一款可进行地理复制、主内存main-memory的高一致性数据存储，其最大特点是将低延时和高事务完美统一。 其模板化的架构： 1. 事务层：基于commit-time事务认证，灵活支持传统数据库的MVCC( Multi-Version Concurrency Control )和 single-versioning。能用来提供串行化serializability 或EUS(Extended Update Serializability )，这些依赖于底层的顺序Order层。 2.顺序层Ordering Layer：一致性的协议是可插拔的，可选择偏序(partial order)协议，如 Alvin POB, M2Paxos 或 E‑Paxos；或者完整顺序协议...阅读全文
// Pipe适配器是用来连接期望一个io.Reader的代码和期望一个io.Writer的代码 package my_io import ( "errors" "sync" ) // onceError是一个只会存储一次错误的对象 type onceError struct { sync.Mutex //解析见下面 err error } func (a *onceError) Store(err error) { a.Lock() defer a.Unlock() if a.err!=nil{ return } a.err=err } func (a *onceError) Load() error { a.Lock() defer a.Unlock() return a.err } /...阅读全文
