example.R

In armaninspace/rjobkernel:

library(processx)
library(rjobkernel)

Lsize <<- 0
rear <<- new.env()
Lqueue <<- new.env()

enqueue(list(val='/home/armaninspace/jobs/job1.R'))
enqueue(list(val='/home/armaninspace/jobs/job2.R'))
enqueue(list(val='/home/armaninspace/jobs/job3.R'))

count <- 1

while(!isEmptyQueue()) {
  ll <- bottom()
  procname <- paste0('p',count)
  cat('Process Name:',procname,"\n")
  filepath <- ll$val
  Sys.sleep(10)
  procname <- process$new("Rscript", filepath)
  print(procname)
  dequeue();
  count <- count + 1
}