fun.go

package captainslog                                                                            
                                                                                               
import "sync"                                                                                  
                                                                                               
type Queue struct {                                                                            
    q    []SyslogMsg                                                                           
    lock *sync.Mutex                                                                           
}                                                                                              
                                                                                               
func NewQueue(max int) *Queue {                                                                
    return &Queue{                                                                             
        lock: &sync.Mutex{},                                                                   
        q:    make([]SyslogMsg, 0, max),                                                       
    }                                                                                          
}                                                                                              
                                                                                               
func (q *Queue) Enqueue(s SyslogMsg) {                                                         
    q.lock.Lock()                                                                              
    defer q.lock.Unlock()                                                                      
    q.q = append(q.q, s)                                                                       
}                                                                                              
                                                                                               
func (q *Queue) Dequeue() SyslogMsg {                                                          
    q.lock.Lock()                                                                              
    defer q.lock.Unlock()                                                                      
    m := q.q[0]                                                                                
    q.q = q.q[1:]                                                                              
    return m                                                                                   
}                                                                                              
                                                                                               
func (q *Queue) Len() int {                                                                    
    return len(q.q)                                                                            
}