qlib.sh File Reference

Go to the source code of this file.

Functions
function	put_queue ()
function	puts_queue ()
function	queue ()

Function Documentation

function put_queue

(

)

Definition at line 19 of file qlib.sh.

{
    queue_name=$1
    shift
    
    echo -n "$*;" >> $queue_name
}

function puts_queue

(

)

Definition at line 34 of file qlib.sh.

{
    queue_name=$1
    shift
    
    echo "$*" >> $queue_name
}

function queue

(

)

Definition at line 50 of file qlib.sh.

{
    queue_name=$1
    queue_size=$2
    sleep_time=$3

    if [[ -e $queue_name ]]; then

        if [[ -p $queue_name ]]; then
            fatal "Queue $queue_name in use."
        fi    
    else
        
        mkfifo $queue_name                                # create a new FIFO
    fi

    fd=7                                                  # file descriptor

    eval "exec $fd<>$queue_name"                          # attach file descriptor to FIFO

    while read job <& $fd; do                             # read job from file descriptor
        
        if [[ -n $job ]]; then
            
            if [[ $job = "exit" ]]; then
                break
            fi

            notice "submit $job" 
            eval exec $job &                              # submit job

            # wait for free slot
        
            while (( ${#jobstates} >= $queue_size )); do
                sleep $sleep_time
            done
        fi
    done
    
    rm -f $queue_name                                     # remove FIFO
}