From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

KIMOTO / SPVM-0.990056 / t / 02_vm / lib / SPVM / TestCase / ThreadSafe.spvm 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

              
class TestCase::ThreadSafe {
  use Point;
  use TestCase::Util::Thread;
  use TestCase::Util::Thread::ID;
  use TestCase::Util::Thread::ThisThread;
  use TestCase::Operator::Data::Weaken;
   
  static method assign : int () {
     
    # undef
    {
      my $point_ref = [(Point)undef];
       
      my $thread = TestCase::Util::Thread->new([$point_ref : Point[]] method : void () {
         
        for (my $i = 0; $i < 10000; $i++) {
          my $point = Point->new;
          $point_ref->[0] = $point;
        }
      });
       
      my $thread2 = TestCase::Util::Thread->new([$point_ref : Point[]] method : void () {
        for (my $i = 0; $i < 10000; $i++) {
          $point_ref->[0] = undef;
        }
      });
       
      $thread->join;
      $thread2->join;
       
    }
    # All patterns
    {
      my $point_ref = [(Point)undef];
       
      my $thread = TestCase::Util::Thread->new([$point_ref : Point[]] method : void () {
         
        for (my $i = 0; $i < 10000; $i++) {
          my $point = Point->new;
          $point_ref->[0] = $point;
          $point_ref->[0] = $point;
          $point_ref->[0] = Point->new;
          $point_ref->[0] = undef;
          $point_ref->[0] = Point->new;
        }
      });
       
      my $thread2 = TestCase::Util::Thread->new([$point_ref : Point[]] method : void () {
         
        for (my $i = 0; $i < 10000; $i++) {
          my $point = Point->new;
          $point_ref->[0] = $point;
          $point_ref->[0] = $point;
          $point_ref->[0] = Point->new;
          $point_ref->[0] = undef;
          $point_ref->[0] = Point->new;
        }
      });
       
      $thread->join;
      $thread2->join;
       
      unless ($point_ref->[0] is_type Point) {
        return 0;
      }
    }
     
    return 1;
  }
  static method weaken : int () {
    my $object1 = new TestCase::Operator::Data::Weaken;
    $object1->{x} =1;
     
    my $object2 = new TestCase::Operator::Data::Weaken;
    $object2->{x} = 2;
     
    # Circular reference
    $object2->{data_weaken} = $object1;
    $object1->{data_weaken} = $object2;
     
    {
      my $object_ref = [(TestCase::Operator::Data::Weaken)$object1, $object2];
       
      my $thread = TestCase::Util::Thread->new([$object_ref : TestCase::Operator::Data::Weaken[]] method : void () {
         
        for (my $i = 0; $i < 10000; $i++) {
          my $object = $object_ref->[0];
          weaken $object->{data_weaken};
          $object->{data_weaken} = $object->{data_weaken};
          unweaken $object->{data_weaken};
          $object->{data_weaken} = $object->{data_weaken};
          isweak $object->{data_weaken};;
        }
      });
       
      my $thread2 = TestCase::Util::Thread->new([$object_ref : TestCase::Operator::Data::Weaken[]] method : void () {
         
        for (my $i = 0; $i < 10000; $i++) {
          my $object = $object_ref->[0];
          weaken $object->{data_weaken};
          $object->{data_weaken} = $object->{data_weaken};
          unweaken $object->{data_weaken};
          $object->{data_weaken} = $object->{data_weaken};
          isweak $object->{data_weaken};;
        }
      });
       
      $thread->join;
      $thread2->join;
       
      unless ($object1->{x} == 1 && $object2->{x} == 2) {
        return 0;
      }
       
      weaken $object1->{data_weaken};
    }
     
    return 1;
  }
}