Как правильнее хранить данные?

Question

[Владимир Грабко]

У меня есть список команд. Так как команды выполняются синхронно мне необходимо сделать очередь команд.
думаю заделать глобальный map который в рутине буду перебирать при помощи цикла.

Comments

[Виталий Филинков]

Вас не смущает то, что данные в мар будут отдаваться в цикле рандомно, а не в той последовательности, как заносились?

[Владимир Грабко]

Виталий Филинков: это я решу с помощью "счётчика команд" в него буду писать ид добавленной команды и в цикле буду перебирать эти id, а в теле цыкла по этому id я буду делать выборку с основного мапа

[Илья]

Главное про mutex не забывайте.

[Владимир Грабко]

FireGM: блокировку необходимо ставить всегда при чтении и записи? Верно?

[Илья]

Владимир Грабко: В вашем случае, да.

[Владимир Грабко]

FireGM:

package main

import (
	"fmt"
	"log"
	"net"
	"strconv"
	"strings"
	"sync"
	"time"
)

var commandCounter int
var commandCounterEnter int
var command map[int]string
var mutex *sync.Mutex

func SocketClient(ip string, port int) {

	addr := strings.Join([]string{ip, strconv.Itoa(port)}, ":")
	conn, err := net.Dial("tcp", addr)

	defer conn.Close()

	if err != nil {
		log.Fatalln(err)
	}

	//conn.Write([]byte(message))
	//log.Printf("Send: %s", message)

	buff := make([]byte, 1024)
	n, _ := conn.Read(buff)

	//добавляем команду в очередь
	mutex.Lock()
	commandCounter = commandCounter + 1
	mutex.Unlock()
	mutex.Lock()
	command[commandCounter] = fmt.Sprintf("%s", buff[:n])
	mutex.Unlock()
	SocketClient(ip, port)
}

func main() {
	mutex = &sync.Mutex{}

	log.Printf("Started")
	command = make(map[int]string)
	go func() {
		i := 1
		for {
			if i <= commandCounter {
				if commandCounterEnter < i {
					commandCounterEnter = i
					mutex.Lock()
					log.Print(command[i])
					mutex.Unlock()
					i = i + 1
				} else {
					time.Sleep(1 * time.Minute)
				}
			} else {
				time.Sleep(1 * time.Minute)
			}
		}
	}()

	var (
		ip   = "46.63.122.27"
		port = 3333
	)
	SocketClient(ip, port)
}

Правильно сделал блокировку?

[Илья]

Владимир Грабко: Вы не умеете пользоваться структурами? Вынесите счетчик с блокировкой в отдельный объект. И счетчик надо инкриментить внутри блокировки.

[Илья]

И вообще, у вас ужас, а не код.

[Владимир Грабко]

FireGM: код специально "усложняется". Говнокод антивирусы очень нескоро определят как вредоноса)

[Виталий Филинков]

Владимир Грабко: зачем городить отдельный счетчик? Про очередь что-нибудь слышали?

[Владимир Грабко]

Виталий Филинков: я и хотел её сделать. В гугле нашел только клиенты к разным серверам очередей, а мне нужна встроенная очередь

[Виталий Филинков]

Владимир Грабко: книги по алгоритмам и структурам данных читать не пробовали?

[Владимир Грабко]

Виталий Филинков: нее. не пробивал. Посоветуете что то?

[Виталий Филинков]

Владимир Грабко:
Алгоритмы - www.ozon.ru/context/detail/id/33769775
Структуры данных и алгоритмы (там про java, но не суть) www.ozon.ru/context/detail/id/23529814

Answer 1

[uvelichitel]

Терминология путаная. map это не очередь, channel это очередь. Очередь можно сделать из slice или list реализовав методы Put и Get. map нужен для прямого доступа по имени, для перебора в цикле slice дешевле и детерминированней.

Answer 2

[Владимир Грабко]

command = make(map[int]string)

	commandCounter = commandCounter + 1
	command[commandCounter] = "test"

	commandCounter = commandCounter + 1
	command[commandCounter] = "test2"

	commandCounter = commandCounter + 1
	command[commandCounter] = "test3"

	i := 1
	for i <= commandCounter {
		log.Print(command[i])
		i = i + 1
	}

вот и простейшая очередь. Конечно в рутине цикл будет бесконечным + защита от повторного запуска команды

Comments

[Tyranron]

А что будет когда commandCounter переполнится?

[Владимир Грабко]

Tyranron: мне тоже это очень интересно)

[Владимир Грабко]

Tyranron: я так думаю что софт упадёт

[Илья]

Tyranron: Вам не хватит отведенного времени для вашей жизни, чтобы узнать это. А если поставить uint64, а счетчик будет увеличиваться каждую милисекунду, то потребуется 500кк лет. В общем, не переполнится.