Ангел обнови решението на 26.12.2015 16:06 (преди над 2 години)
+package main
+
+import (
+ "sync"
+)
+
+type Request interface {
+ ID() string
+ Run() (result interface{}, err error)
+ Cacheable() bool
+ SetResult(result interface{}, err error)
+}
+
+type Requester interface {
+ AddRequest(request Request)
+ Stop()
+}
+
+type requestResult struct {
+ result interface{}
+ err error
+ cacheable bool
+ locker *sync.Mutex
+ id string
+}
+
+type MyRequester struct {
+ mapLocker *sync.Mutex
+ throttleLocker chan struct{}
+ results *buffer
+ running bool
+}
+
+type buffer struct {
+ data []*requestResult
+ size int
+ last int
+}
+
+func newBuffer(maxSize int) *buffer {
+ return &buffer{
+ data: make([]*requestResult, maxSize),
+ size: 0,
+ last: 0,
+ }
+}
+
+func (b *buffer) push(result *requestResult) {
+ b.data[b.last] = result
+ b.last = (b.last + 1) % cap(b.data)
+ if b.size < b.last {
+ b.size = b.last
+ }
+}
+
+func (b *buffer) get(id string) (*requestResult, bool) {
+ for i := 0; i < b.size; i++ {
+ if b.data[i].id == id {
+ return b.data[i], true
+ }
+ }
+ return nil, false
+}
+
+func NewRequester(cacheSize int, throttleSize int) Requester {
+ return &MyRequester{
+ mapLocker: &sync.Mutex{},
+ throttleLocker: make(chan struct{}, throttleSize),
+ results: newBuffer(cacheSize),
+ running: true,
+ }
+}
+
+func (m *MyRequester) AddRequest(request Request) {
+ if !m.running {
+ return
+ }
+
+ m.throttleLocker <- struct{}{}
+
+ id := request.ID()
+
+ m.mapLocker.Lock()
+ result, ok := m.results.get(id)
+ if !ok {
+ result = &requestResult{
+ locker: &sync.Mutex{},
+ cacheable: false,
+ id: id,
+ }
+ m.results.push(result)
+ }
+ m.mapLocker.Unlock()
+
+ result.locker.Lock()
+ if result.cacheable {
+ request.SetResult(result.result, result.err)
+ } else {
+ result.result, result.err = request.Run()
+ result.cacheable = request.Cacheable()
+ }
+ result.locker.Unlock()
+
+ <-m.throttleLocker
+}
+
+func (m *MyRequester) Stop() {
+ m.running = false
+}
Весела Коледа.
Много добро количество локове. Принципно има и други начини, но и този става. В допълнение по темата: ако си ръннеш кода с '-race' и извикваш Stop и AddRequest ще ти каже че има racecondtion на m.running. Това не смятам че е проблем, но може да го оправиш.
Проблема е имплементацията на cache-а която нещо неработи 
.
Също така ако пазиш нещо в кеша преди да знаеш дали е кешируемо ще ти напълни кеша с неща които не са кешируеми и няма да имаш място за друго 
btw, стойностите в go се инициализират на 0 така че ред 43,44 не са необходими
Весели празници и приятно кодене