dist/Storable/t/threads.t

   1
   2 # as of 2.09 on win32 Storable w/threads dies with "free to wrong
   3 # pool" since it uses the same context for different threads. since
   4 # win32 perl implementation allocates a different memory pool for each
   5 # thread using the a memory pool from one thread to allocate memory
   6 # for another thread makes win32 perl very unhappy
   7 #
   8 # but the problem exists everywhere, not only on win32 perl , it's
   9 # just hard to catch it deterministically - since the same context is
  10 # used if two or more threads happen to change the state of the
  11 # context in the middle of the operation, and those operations aren't
  12 # atomic per thread, bad things including data loss and corrupted data
  13 # can happen.
  14 #
  15 # this has been solved in 2.10 by adding a Storable::CLONE which calls
  16 # Storable::init_perinterp() to create a new context for each new
  17 # thread when it starts
  18
  19 sub BEGIN {
  20     unshift @INC, 't';
  21     unshift @INC, 't/compat' if $] < 5.006002;
  22     require Config; import Config;
  23     if ($ENV{PERL_CORE} and $Config{'extensions'} !~ /\bStorable\b/) {
  24         print "1..0 # Skip: Storable was not built\n";
  25         exit 0;
  26     }
  27     unless ($Config{'useithreads'} and eval { require threads; 1 }) {
  28         print "1..0 # Skip: no threads\n";
  29         exit 0;
  30     }
  31     # - is \W, so can't use \b at start. Negative look ahead and look behind
  32     # works at start/end of string, or where preceded/followed by spaces
  33     if ($] == 5.008002 and eval q{ $Config{'ccflags'} =~ /(?<!\S)-DDEBUGGING(?!\S)/ }) {
  34         # Bug caused by change 21610, fixed by change 21849
  35         print "1..0 # Skip: tickles bug in threads combined with -DDEBUGGING on 5.8.2\n";
  36         exit 0;
  37     }
  38 }
  39
  40 use Test::More;
  41
  42 use strict;
  43
  44 use threads;
  45 use Storable qw(nfreeze);
  46
  47 plan tests => 2;
  48
  49 threads->new(\&sub1);
  50
  51 $_->join() for threads->list();
  52
  53 ok 1;
  54
  55 sub sub1 {
  56     nfreeze {};
  57     ok 1;
  58 }