#!/usr/bin/perl -w
use strict; use warnings;

use MCE::Hobo;
use MCE::Shared;
use Time::HiRes qw(time sleep);

# Use monotonic clock if available.
use constant CLOCK_MONOTONIC => eval {
    Time::HiRes::clock_gettime( Time::HiRes::CLOCK_MONOTONIC() );
    1;
};
sub _time {
    ( CLOCK_MONOTONIC )
      ? Time::HiRes::clock_gettime( Time::HiRes::CLOCK_MONOTONIC() )
      : Time::HiRes::time();
}

my $DEBUG = 1;
my $INTERVAL = $DEBUG ? 3.0 : 60.0;

my $PRICING = MCE::Shared->scalar(0);
my $RUNNING = MCE::Shared->scalar(1);

sub price_thread {
    my $next_interval = _time() + $INTERVAL;
    while ($RUNNING->get()) {
        printf("# TIME %.3f\n", _time()) if $DEBUG;
        # Local variable to limit lock time.
        # Catch errors in eval
        my $pricing = eval {
            # Net::Curl to remote URL... request here.
            my $val = 1000 * rand(); # [from net::curl]
            # ... more?
            # last line will go to $pricing and $pricing gets undef on exception
            $val
        };

        $PRICING->set($pricing);

        # Pause between requests:
        my $time = _time();
        if ($time > $next_interval) {
            # Wait till next interval if curl time is greater than $INTERVAL.
            $next_interval += $INTERVAL while $next_interval < $time;
        }
        sleep $next_interval - $time;
        $next_interval += $INTERVAL;
    }
}

sub main_loop {
    # Local variable to limit lock time and prevent changes mid-computation
    my $pricing = 0;
    while ($RUNNING->get()) {
        $pricing = $PRICING->get();

        # Optional - I don't know what you are doing with pricing, you might want
        # to use 0 or undef to signal a request error (i.e., out-of-date data).
        next if !defined($pricing) or $pricing == 0;

        # Do something with $pricing;
        print "$pricing\n";
        sleep 1; # Work simulation

        # return if QUIT CONDITION;
    }
}

my $thr = MCE::Hobo->create({ void_context => 1 }, \&price_thread);
eval { main_loop() };
$RUNNING->set(0);
$thr->join();