Как элегантно реализовать задания на сайте?

Question

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

Добрый день. Мне необходимо реализовать миссии (к примеру помиловать двух игроков) я бы мог написать инструкцию проверки прямо в функции помилования но тогда прийдётся очень туго с добавлением новых миссий и редактированием старых (по всему коду же разбросаны). Я хочу это всё сделать в одном месте. На ум пришла 1 бредовая идея: все обработчики отправлять колбеком в функцию обработчик миссий

Answer 1

[Никита]

Как вариант.
Если пользуетесь каким-то фреймворком, то возможно там есть система ивентов, если нет, то пишите свою. Далее, каждое успешное действие запускает триггер своего глобального евента. А всю логику уже можно обрабатывать в отдельном компоненте, подписавшись на нужные вам ивенты.
Сразу скажу, будет проблема с передачей аргументов, особенно нужен будет контекст, но фреймворки обычно решают этим проблемы.

Comments

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

Стандартная библиотека. Только хардкор))

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

Ну очень простые события. Вызывать буду в каждой функции, а обработка всех событий в одном месте. Думаю не сильный говнокод

package events

var Event map[string]func(ps []string)

func init() {
	Event = make(map[string]func(ps []string))
}

// Подписка на событие
func Add(name string, callback func(ps []string)) {
	Event[name] = callback
}

// Вызов события
func Call(name string, ps []string) {
	Event[name](ps)
}

[Никита]

Владимир Грабко: Только это не потокобезопасно. https://github.com/chuckpreslar/emission вот расширенная версия вашего творения

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

Никита: что бы сделать потокобезопасним то необходимо добавить блокировки? У меня просто очень много кода по такому принципу сделано

[Никита]

Владимир Грабко: ну да, или мьютексы или каналы, но, конечно, вопрос в том - "нужно это или нет?". Если у вас все подписи на события будут в init() методах, то оно и не надо, а если динамически (т.е. в любом методе если это web-сервис), то потокобезопасность обязательна.

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

Никита: тоесть блокировать необходимо при записи, а при чтении нет. Блокировки проводить как то так

maxDataLock.Lock()
	Event[name] = callback
	maxDataLock.Unlock()

Верно?

[Никита]

Владимир Грабко: При чтении тоже нужна блокировка. Возьмите либу, что я посоветовал, нормальная она, не большая (всего 1 файл то) =)

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

Никита: я сам хочу понять как оно работает. Я прост только что понял что у меня целая куча потоко не безопасного кода. И последний вопрос. Если я создал глобальную переменную sync.Mutex то её можно потом юзать во всех функциях или для каждой необходимо пересоздавать?

Answer 2

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

package events

import (
	"sync"
)

var Event map[string]func(ps []string)

func init() {
	Event = make(map[string]func(ps []string))
}

// Подписка на событие
func Add(name string, callback func(ps []string)) {
	rw := &sync.RWMutex{}
	rw.Lock()
	defer rw.Unlock()

	Event[name] = callback

}

// Вызов события
func Call(name string, ps []string) {
	rw := &sync.RWMutex{}
	rw.RLock()
	defer rw.RUnlock()
	go Event[name](ps)

}

Comments

[Oleg Shevelev]

Вы уверены что так правильно? Суть вот в чём, вы при каждом вызове Add() и Call() делаете новую переменную для лока, а значит если параллельно и конкурентно вызвать одну и туже функцию дважды, то будет два отдельных лока и в результате переменная Event не защищена никак.

Ниже отправил код в виде отдельного ответа.

Answer 3

[Oleg Shevelev]

https://play.golang.org/p/NJ-X38UrWC

В дополнение к комментарию на другой ответ.

package events

import (
  "sync"
)

var events *Events

type Events struct {
    sync.RWMutex
    list map[string]func(ps []string)
}

func NewEventsList() (list *Events) {
    list = new(Events)
    list.list = make(map[string]func(ps []string))
    return list
}

func init() {
  events = NewEventsList()
}

func Add(name string, callback func(ps []string)) {
    events.Add(name, callback)
}

func Call(name string, ps []string) bool {
    return events.Call(name, ps)
}


// Подписка на событие
func (l *Events) Add(name string, callback func(ps []string)) {
    l.Lock()
    defer l.Unlock()
    l.list[name] = callback
}

// Вызов события
func (l *Events) Call(name string, ps []string) bool {
    l.RLock()
    defer l.RUnlock()
    if f, ok := l.list[name]; ok {
        go f(ps)
        return true
    }
    return false
}