Почему в результате дублируются цифры?

Question

[Sergey Romanov]

Вот такой код

package main

import (
	"encoding/json"
	"fmt"
)

type Test1 map[string]interface{}

var c chan Test1

func main() {
	val := Test1{
		"s": 1,
		"w": 2,
	}

	c = make(chan Test1, 3)

	go run()

	for i := 0; i < 10; i++ {
		val["v"] = i

		c <- val
	}
}
func run() {
	for {
		a := <-c
		out, _ := json.Marshal(a)
		fmt.Println(string(out))
	}
}

Возращает

{"s":1,"v":3,"w":2}
{"s":1,"v":4,"w":2}
{"s":1,"v":4,"w":2}
{"s":1,"v":4,"w":2}
{"s":1,"v":4,"w":2}
{"s":1,"v":9,"w":2}
{"s":1,"v":9,"w":2}
{"s":1,"v":9,"w":2}
{"s":1,"v":9,"w":2}
{"s":1,"v":9,"w":2}

Почему порядок не 1,2,3,4, ну или рэндом не обязательно по порядку, но главно почему пропущены некотрые цифры. Как это справить не меняя структуры? Это просто небольшая реплика проблемы большой программы.

Короче есть цикл, у нем идет обработка данных и отправка в канал. Оптарляется структура. Большоая часть струтуры заполняется до цикла. В цикле много условий, если там дублировать то будет месево.

Answer 1

[uvelichitel]

Потому что map ссылочный тип и вы все время посылаете в канал ссылку на одну и ту же мапу. Нужно копировать map и посылать новую копию. (Ну или использовать не map а struct)

for i := 0; i < 10; i++ {
	// Create new map
	val1 := make(map[string]interface{})
	// Copy from the original map to the target map
	for key, value := range val {
		val1[key] = value
	}
	val1["v"] = i
	c <- val1
}

Play https://play.golang.org/p/eIxdPQfkzCi
Версия 0.1
Поскольку map ссылочный тип передавать его через канал - мало смысла. Можно защитить и синхронизировать простым sync.Mutex например так

package main
import (
	"encoding/json"
	"fmt"
	"sync"
)
type Test1 map[string]interface{}
var R sync.Mutex
var W sync.Mutex
var val = Test1{
	"s": 1,
	"w": 2,
}
func main() {
	R.Lock()
	go run()
	for i := 0; i < 10; i++ {
		W.Lock()
		val["v"] = i
		R.Unlock()
	}
}
func run() {
	for {
		R.Lock()
		out, _ := json.Marshal(val)
		fmt.Println(string(out))
		W.Unlock()
	}
}

Playground https://play.golang.org/p/0uAOlhZuqjL

Comments

[Sergey Romanov]

Понял. Но этот цикл назначения придется делать много раз.

Сейчас я выхожу из функцией в переменной.

type Test1 map[string]interface{}

var c chan map[string]interface{}

func main() {
	c = make(chan map[string]interface{}, 3)
	go run()

	val := func() Test1 {
		return Test1{
			"s": 1,
			"w": 2,
		}
	}

	for i := 0; i < 10; i++ {
		f := val()
		f["v"] = i

		c <- f
	}
	time.Sleep(time.Second)
}
func run() {
	for {
		a := <-c
		out, _ := json.Marshal(a)
		fmt.Println(string(out))
	}
}

[Sergey Romanov]

Sergey Romanov, Если уже прочел первый комент я сразу не понял что ты посоветовал. Извини, теперь понятно.

[uvelichitel]

Sergey Romanov, дополнил ответ

[Sergey Romanov]

uvelichitel, Спасибо, посмотрел. Интересная эта штука мутекс. Полезно. Но мне не подойдет, потому что у меня на этот канал приходят данные не из одного цикла а из десятка а может и сотни рутин и это канал с буфером. Но спасибо всеравно.

[f0rk]

Можно и каналом синхронизировать, вместо мьютекса https://play.golang.org/p/NKz8yTLGPxl

[f0rk]

Но мне не подойдет, потому что у меня на этот канал приходят данные не из одного цикла а из десятка а может и сотни рутин и это канал с буфером

Sergey Romanov, да хоть из тысячи, если рутины пишут в одну и ту же мапку, ее придется защищать тем или иным образом, иначе data race