// ------------------------------------------------------------------------ // Project atila // Active Thing (activething.com) git.activething.com/go // // File name rkey.go // Created by DEV // Modified 05/02/2024 // // Copyright 2024 activething.com // ------------------------------------------------------------------------ // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // ------------------------------------------------------------------------ package crns type ( TimerTaskHeap []*TimerTask ) func (h *TimerTaskHeap) Reset() { *h = (*h)[:0] } func (h *TimerTaskHeap) PushTimerTask(ele *TimerTask) { if ele != nil { *h = append(*h, ele) } } func (h *TimerTaskHeap) PopTimerTask() *TimerTask { th := *h if ln := len(th); ln > 0 { tt := th[ln-1] *h = th[:ln-1] return tt } return nil } func (h *TimerTaskHeap) Push(ele interface{}) { h.PushTimerTask(ele.(*TimerTask)) } func (h *TimerTaskHeap) Pop() interface{} { return h.PopTimerTask() } func (h TimerTaskHeap) Len() int { return len(h) } func (h TimerTaskHeap) Less(i, j int) bool { return h[i].RunAt.Before(h[j].RunAt) } func (h TimerTaskHeap) Swap(i, j int) { h[i], h[j] = h[j], h[i] } /* :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::: I HAVE NO DESIRE TO WALK ON WATER," SAID SIDDHARTA. "LET THE OLD SHRAMANAS SATISFY THEMSELVES WITH SUCH SKILLS. SIDDHARTA - HERMANN HESSE - ::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::: */