qlib.sh

Go to the documentation of this file.

#!/bin/zsh
#
#
# \author mdejong
#
#--------------------------------------------------------------------------------------
#
#                   Utility script for batch queue functions.
#
#--------------------------------------------------------------------------------------


#
# Put command(s) in given queue; do not submit job.
#
# \param   1         queue name
# \param   2-N       command(s)
#
function put_queue()
{
    queue_name=$1
    shift
    
    echo -n "$*;" >> $queue_name
}


#
# Put command(s) in given queue and submit job.
#
# \param   1         queue name
# \param   2-N       command(s)
#
function puts_queue()
{
    queue_name=$1
    shift
    
    echo "$*" >> $queue_name
}


#
# Run queue.
#
# \param   1         queue name
# \param   2         queue size
# \param   3         sleep time
#
function queue()
{
    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
}