ext/threads/shared/t/hv_simple.t

   1
   2 BEGIN {
   3 #    chdir 't' if -d 't';
   4 #    push @INC ,'../lib';
   5     require Config; import Config;
   6     unless ($Config{'useithreads'}) {
   7         print "1..0 # Skip: no useithreads\n";
   8         exit 0;
   9     }
  10 }
  11
  12
  13 sub ok {
  14     my ($id, $ok, $name) = @_;
  15
  16     # You have to do it this way or VMS will get confused.
  17     print $ok ? "ok $id - $name\n" : "not ok $id - $name\n";
  18
  19     printf "# Failed test at line %d\n", (caller)[2] unless $ok;
  20
  21     return $ok;
  22 }
  23
  24 sub skip {
  25     my ($id, $ok, $name) = @_;
  26     print "ok $id # skip _thrcnt - $name \n";
  27 }
  28
  29
  30
  31 use ExtUtils::testlib;
  32 use strict;
  33 BEGIN { print "1..21\n" };
  34 use threads;
  35 use threads::shared;
  36 ok(1,1,"loaded");
  37 my %hash;
  38 share(%hash);
  39 $hash{"foo"} = "bar";
  40 ok(2,$hash{"foo"} eq "bar","Check hash get");
  41 threads->create(sub { $hash{"bar"} = "thread1"})->join();
  42 threads->create(sub { ok(3,$hash{"bar"} eq "thread1", "Check thread get and write")})->join();
  43 {
  44     my $foo = delete($hash{"bar"});
  45     ok(4, $foo eq "thread1", "Check delete, want 'thread1' got '$foo'");
  46     $foo = delete($hash{"bar"});
  47     ok(5, $foo == undef, "Check delete on empty value");
  48 }
  49 ok(6, keys %hash == 1, "Check keys");
  50 $hash{"1"} = 1;
  51 $hash{"2"} = 2;
  52 $hash{"3"} = 3;
  53 ok(7, keys %hash == 4, "Check keys");
  54 ok(8, exists($hash{"1"}) == 1, "Exist on existing key");
  55 ok(9, exists($hash{"4"}) == undef, "Exists on non existing key");
  56 my %seen;
  57 foreach my $key ( keys %hash) {
  58     $seen{$key}++;
  59 }
  60 ok(10, $seen{1} == 1, "Keys..");
  61 ok(11, $seen{2} == 1, "Keys..");
  62 ok(12, $seen{3} == 1, "Keys..");
  63 ok(13, $seen{"foo"} == 1, "Keys..");
  64 threads->create(sub { %hash = () })->join();
  65 ok(14, keys %hash == 0, "Check clear");
  66 skip(15, threads::shared::_thrcnt(%hash) == 1, "thrcnt");
  67 threads->create(sub { skip(16, threads::shared::_thrcnt(%hash) == 2, "thrcnt is up")})->join();
  68 skip(17, threads::shared::_thrcnt(%hash) == 1, "thrcnt is down");
  69 {
  70         my $test;
  71         my $test2;
  72         share($test);
  73         $test = \%hash;
  74         $test2 = \%hash;
  75         skip(18, threads::shared::_thrcnt(%hash) == 2, "thrcnt is up on shared reference");
  76         $test = "bar";
  77         skip(19 , threads::shared::_thrcnt(%hash) == 1, "thrcnt is down when shared reference is dropped");
  78         $test = $test2;
  79         skip(20, threads::shared::_thrcnt(%hash) == 2, "thrcnt is up on shared reference");
  80 }
  81 skip(21 , threads::shared::_thrcnt(%hash) == 1, "thrcnt is down when shared reference is killed");