| 1 |
|
|---|
| 2 |
|
|---|
| 3 | #
|
|---|
| 4 | # The reason this does not use a Test module is that
|
|---|
| 5 | # they mess up test numbers between threads
|
|---|
| 6 | #
|
|---|
| 7 | # And even when that will be fixed, this is a basic
|
|---|
| 8 | # test and should not rely on shared variables
|
|---|
| 9 | #
|
|---|
| 10 | # This will test the basic API, it will not use any coderefs
|
|---|
| 11 | # as they are more advanced
|
|---|
| 12 | #
|
|---|
| 13 | #########################
|
|---|
| 14 |
|
|---|
| 15 |
|
|---|
| 16 | BEGIN {
|
|---|
| 17 | chdir 't' if -d 't';
|
|---|
| 18 | push @INC, '../lib';
|
|---|
| 19 | require Config; import Config;
|
|---|
| 20 | unless ($Config{'useithreads'}) {
|
|---|
| 21 | print "1..0 # Skip: no useithreads\n";
|
|---|
| 22 | exit 0;
|
|---|
| 23 | }
|
|---|
| 24 | }
|
|---|
| 25 |
|
|---|
| 26 | use ExtUtils::testlib;
|
|---|
| 27 | use strict;
|
|---|
| 28 | BEGIN { $| = 1; print "1..19\n" };
|
|---|
| 29 | use threads;
|
|---|
| 30 |
|
|---|
| 31 |
|
|---|
| 32 |
|
|---|
| 33 | print "ok 1\n";
|
|---|
| 34 |
|
|---|
| 35 |
|
|---|
| 36 | #########################
|
|---|
| 37 |
|
|---|
| 38 |
|
|---|
| 39 |
|
|---|
| 40 |
|
|---|
| 41 | sub ok {
|
|---|
| 42 | my ($id, $ok, $name) = @_;
|
|---|
| 43 |
|
|---|
| 44 | # You have to do it this way or VMS will get confused.
|
|---|
| 45 | print $ok ? "ok $id - $name\n" : "not ok $id - $name\n";
|
|---|
| 46 |
|
|---|
| 47 | printf "# Failed test at line %d\n", (caller)[2] unless $ok;
|
|---|
| 48 |
|
|---|
| 49 | return $ok;
|
|---|
| 50 | }
|
|---|
| 51 |
|
|---|
| 52 |
|
|---|
| 53 |
|
|---|
| 54 | sub test1 {
|
|---|
| 55 | ok(2,'bar' eq $_[0],"Test that argument passing works");
|
|---|
| 56 | }
|
|---|
| 57 | threads->create('test1','bar')->join();
|
|---|
| 58 |
|
|---|
| 59 | sub test2 {
|
|---|
| 60 | ok(3,'bar' eq $_[0]->[0]->{foo},"Test that passing arguments as references work");
|
|---|
| 61 | }
|
|---|
| 62 |
|
|---|
| 63 | threads->create('test2',[{foo => 'bar'}])->join();
|
|---|
| 64 |
|
|---|
| 65 |
|
|---|
| 66 | #test execuion of normal sub
|
|---|
| 67 | sub test3 { ok(4,shift() == 1,"Test a normal sub") }
|
|---|
| 68 | threads->create('test3',1)->join();
|
|---|
| 69 |
|
|---|
| 70 |
|
|---|
| 71 | #check Config
|
|---|
| 72 | ok(5, 1 == $threads::threads,"Check that threads::threads is true");
|
|---|
| 73 |
|
|---|
| 74 | #test trying to detach thread
|
|---|
| 75 |
|
|---|
| 76 | sub test4 { ok(6,1,"Detach test") }
|
|---|
| 77 |
|
|---|
| 78 | my $thread1 = threads->create('test4');
|
|---|
| 79 |
|
|---|
| 80 | $thread1->detach();
|
|---|
| 81 | threads->yield; # help out non-preemptive thread implementations
|
|---|
| 82 | sleep 2;
|
|---|
| 83 | ok(7,1,"Detach test");
|
|---|
| 84 |
|
|---|
| 85 |
|
|---|
| 86 |
|
|---|
| 87 | sub test5 {
|
|---|
| 88 | threads->create('test6')->join();
|
|---|
| 89 | ok(9,1,"Nested thread test");
|
|---|
| 90 | }
|
|---|
| 91 |
|
|---|
| 92 | sub test6 {
|
|---|
| 93 | ok(8,1,"Nested thread test");
|
|---|
| 94 | }
|
|---|
| 95 |
|
|---|
| 96 | threads->create('test5')->join();
|
|---|
| 97 |
|
|---|
| 98 | sub test7 {
|
|---|
| 99 | my $self = threads->self();
|
|---|
| 100 | ok(10, $self->tid == 7, "Wanted 7, got ".$self->tid);
|
|---|
| 101 | ok(11, threads->tid() == 7, "Wanted 7, got ".threads->tid());
|
|---|
| 102 | }
|
|---|
| 103 |
|
|---|
| 104 | threads->create('test7')->join;
|
|---|
| 105 |
|
|---|
| 106 | sub test8 {
|
|---|
| 107 | my $self = threads->self();
|
|---|
| 108 | ok(12, $self->tid == 8, "Wanted 8, got ".$self->tid);
|
|---|
| 109 | ok(13, threads->tid() == 8, "Wanted 8, got ".threads->tid());
|
|---|
| 110 | }
|
|---|
| 111 |
|
|---|
| 112 | threads->create('test8')->join;
|
|---|
| 113 |
|
|---|
| 114 |
|
|---|
| 115 | #check support for threads->self() in main thread
|
|---|
| 116 | ok(14, 0 == threads->self->tid(),"Check so that tid for threads work for main thread");
|
|---|
| 117 | ok(15, 0 == threads->tid(),"Check so that tid for threads work for main thread");
|
|---|
| 118 |
|
|---|
| 119 | {
|
|---|
| 120 | no warnings;
|
|---|
| 121 | local *CLONE = sub { ok(16, threads->tid() == 9, "Tid should be correct in the clone")};
|
|---|
| 122 | threads->create(sub { ok(17, threads->tid() == 9, "And tid be 9 here too") })->join();
|
|---|
| 123 | }
|
|---|
| 124 |
|
|---|
| 125 | {
|
|---|
| 126 |
|
|---|
| 127 | sub Foo::DESTROY {
|
|---|
| 128 | ok(19, threads->tid() == 10, "In destroy it should be correct too" )
|
|---|
| 129 | }
|
|---|
| 130 | my $foo;
|
|---|
| 131 | threads->create(sub { ok(18, threads->tid() == 10, "And tid be 10 here");
|
|---|
| 132 | $foo = bless {}, 'Foo';
|
|---|
| 133 | return undef;
|
|---|
| 134 | })->join();
|
|---|
| 135 |
|
|---|
| 136 | }
|
|---|
| 137 | 1;
|
|---|
| 138 |
|
|---|
| 139 |
|
|---|
| 140 |
|
|---|
| 141 |
|
|---|
| 142 |
|
|---|
| 143 |
|
|---|
| 144 |
|
|---|