NAME

Test::SharedObject - Data sharing in multi process.

SYNOPSIS

    use strict;
    use warnings;

    use Test::More tests => 2;
    use Test::SharedFork;
    use Test::SharedObject;

    my $shared = Test::SharedObject->new(0);
    is $shared->get, 0;

    my $pid = fork;
    die $! unless defined $pid;
    if ($pid == 0) {# child
        $shared->txn(sub {
            my $counter = shift;
            $counter++;
            return $counter;
        });
        exit;
    }
    wait;

    is $shared->get, 1;

DESCRIPTION

Test::SharedObject provides atomic data operation between multiple process.

METHODS

my $shared = Test::SharedObject->new($value)

Creates a new Test::SharedObject instance. And set $value as initial value.

Internally, Creates temporary file, and serialize $value by Storable, and save.

$shared->txn(\&coderef)

Provides atomic data operation between multiple process in \&coderef. Set shared value as first arguments in \&coderef, and return value as new shared value.

Internally:

Lock temporary file.

Read shared value.

Executes \&coderef. (Set shared value as first arguments)

Write return value as shared value.

Unlock temporary file.

Good Example:

    $shared->txn(sub {
        my $counter = shift;
        $counter++; # atomic!!
        return $counter;
    });

Bad Example:

    my $counter;
    $shared->txn(sub {
        $counter = shift;
    });
    $counter++; # *NOT* atomic!!
    $shared->txn(sub {
        return $counter;
    });

$shared->set($value)

Set $value as shared value. The syntactic sugar for $shared->txn().

my $value = $shared->get()

Get shared value. The syntactic sugar for $shared->txn().

LICENSE

Copyright (C) karupanerura.

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.

AUTHOR

karupanerura <karupa@cpan.org>