package queue

import (
	"gitee.com/h79/goutils/common/timer"
	"reflect"
)

var PriorityType = reflect.TypeOf((*IPriority)(nil)).Elem()

type IPriority interface {
	GValue() interface{}
	PValue() int64 //优先级值，越小越前
}

// PriorityItem 优先级
type PriorityItem struct {
	Value    interface{}
	Priority int64
}

func (it *PriorityItem) GValue() interface{} {
	return it.Value
}

func (it *PriorityItem) PValue() int64 {
	return it.Priority
}

func NewPriorityItem(elem interface{}) IPriority {
	if p, ok := elem.(*PriorityItem); ok {
		return p
	}
	if it, ok := elem.(PriorityItem); ok {
		return &it
	}
	val := reflect.ValueOf(elem)
	if val.CanInterface() && val.Type().Implements(PriorityType) {
		fm := val.Interface().(IPriority)
		return fm
	}
	return &PriorityItem{Value: elem, Priority: timer.NowNano()}
}