分享
Golang、python线程小列子。。。。。。
大洋的顶端 · · 1476 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
每天成长一小步,积累下来就是一大步。
在GO中,开启15个线程,每个线程把全局变量遍历增加100000次,因此预测结果是 15*100000=1500000.
var sum int
var cccc int
var m *sync.Mutex
func Count1(i int, ch chan int) {
for j := 0; j < 100000; j++ {
cccc = cccc + 1
}
ch <- cccc
}
func main() {
m = new(sync.Mutex)
ch := make(chan int, 15)
for i := 0; i < 15; i++ {
go Count1(i, ch)
}
for i := 0; i < 15; i++ {
select {
case msg := <-ch:
fmt.Println(msg)
}
}
}
但是最终的结果,406527
说明需要加锁。
func Count1(i int, ch chan int) {
m.Lock()
for j := 0; j < 100000; j++ {
cccc = cccc + 1
}
ch <- cccc
m.Unlock()
}
最终输出:1500000
python中:同样方式实现,也不行。
count = 0 def sumCount(temp): global count for i in range(temp): count = count + 1 li = [] for i in range(15): th = threading.Thread(target=sumCount, args=(1000000,)) th.start() li.append(th) for i in li: i.join() print(count)
输出结果:3004737
说明也需要加锁:
mutex = threading.Lock() count = 0 def sumCount(temp): global count mutex.acquire() for i in range(temp): count = count + 1 mutex.release() li = [] for i in range(15): th = threading.Thread(target=sumCount, args=(1000000,)) th.start() li.append(th) for i in li: i.join() print(count)
输出1500000
OK,加锁的小列子。
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信1476 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
每天成长一小步,积累下来就是一大步。
在GO中,开启15个线程,每个线程把全局变量遍历增加100000次,因此预测结果是 15*100000=1500000.
var sum int
var cccc int
var m *sync.Mutex
func Count1(i int, ch chan int) {
for j := 0; j < 100000; j++ {
cccc = cccc + 1
}
ch <- cccc
}
func main() {
m = new(sync.Mutex)
ch := make(chan int, 15)
for i := 0; i < 15; i++ {
go Count1(i, ch)
}
for i := 0; i < 15; i++ {
select {
case msg := <-ch:
fmt.Println(msg)
}
}
}
但是最终的结果,406527
说明需要加锁。
func Count1(i int, ch chan int) {
m.Lock()
for j := 0; j < 100000; j++ {
cccc = cccc + 1
}
ch <- cccc
m.Unlock()
}
最终输出:1500000
python中:同样方式实现,也不行。
count = 0 def sumCount(temp): global count for i in range(temp): count = count + 1 li = [] for i in range(15): th = threading.Thread(target=sumCount, args=(1000000,)) th.start() li.append(th) for i in li: i.join() print(count)
输出结果:3004737
说明也需要加锁:
mutex = threading.Lock() count = 0 def sumCount(temp): global count mutex.acquire() for i in range(temp): count = count + 1 mutex.release() li = [] for i in range(15): th = threading.Thread(target=sumCount, args=(1000000,)) th.start() li.append(th) for i in li: i.join() print(count)
输出1500000
OK,加锁的小列子。