resource_prioritise_greedy_mutex.go

// Compete compete for resource
func (mux *GreedyMutex) Compete(ctx context.Context, resource interface{}) {
	mux.Lock()
	greedyEntities := []PrioritizedEntity{}
	defer func() { go mux.Compete(ctx, resource) }()
	defer mux.Unlock()
	defer func() {
		var winner PrioritizedEntity
		for _, entity := range greedyEntities {
			if winner == nil || winner.GetPriority() < entity.GetPriority() {
				winner = entity
			}
		}
		if winner != nil {
			winner.AccessResource(resource)
		}
	}()
	// wait until have a request for resource
	entity := <-mux.queue
	greedyEntities = append(greedyEntities, entity)
	c := time.NewTicker(mux.TimeToWait)
	for {
		select {
		case <-ctx.Done():
			return
		case <-c.C:
			c.Stop()
			return
		case entity := <-mux.queue:
			greedyEntities = append(greedyEntities, entity)
		}
	}
}