#!/usr/bin/perl

use warnings;
use strict;

#use R;
#use RReferences;
#&R::initR("--silent");

use threads;
use threads::shared;
use Thread::Queue;

our $queue : shared = Thread::Queue->new;
our $hold : shared;

my $thr = threads->new (\&command_runner);

$hold =1;
$queue->enqueue("ls");
while ($hold) {
    sleep(1);
}
$queue->enqueue("end");

$thr->join();

# Thread for processing functions
sub command_runner {

    use R;
    use RReferences;
    &R::initR("--silent");

    my $run = 1;
    # run until return
    while ($run) {
        # This call will block until the main thread sends the job
        my $job = $queue->dequeue;

    print "j: $job\n";

    if ($job eq "ls"){
        R::ls();
        } elsif ($job eq "end") {
            $run = 0
        }
        { lock $hold; $hold = 0; }
    }
   
}