Unerwartete Ergenisse mit Promise.start (Raku / Perl 6)

[thread]19783[/thread]

Unerwartete Ergenisse mit Promise.start

Tags: perl6 Ähnliche Threads

Leser: 13

Articles: hide open all | hide show old branches

+11 replies

Kuerbis

2015-09-02 12:52

User since
2011-03-20
938 Artikel
BenutzerIn
[default_avatar]

Hallo,

dieses Skript bricht früher oder später ab (it dies). Darf ich $sum so verwenden, wie ich es hier getan habe?

Code (perl): (dl )

#!/usr/bin/env perl6
use v6;

my $n = 20;

my $result;
for ^$n { $result += $_ ** $_ }

for ^10000 {
    my @p;
    my $sum = 0;
    for ^$n -> $i {
        push @p, Promise.start( { $sum += $i ** $i } );
    }
    await @p;
    say $sum;
    die $_ if $sum != $result;
}

Muffi

2015-09-02 14:21

User since
2012-07-18
1465 Artikel
BenutzerIn

Ich kenn mich in Perl6 nicht aus.
In anderen Sprachen: Nein
(Ein Inc ist nicht automatisch atomar/threadsicher)

edit: Und auch $i nicht (in anderen Sprachen)
(hier kommts drauf an, ob in der anonymen Sub die Referenz oder die value auf $i gecaptured wird)
Last edited: 2015-09-02 14:27:05 +0200 (CEST)
1 + 1 = 10
lichtkind

2015-09-02 15:06

User since
2004-03-22
5679 Artikel
ModeratorIn + EditorIn

habs laufen lassen und ich komme jedes mal in race kondition auch wenn manchmal beim dritten mal manchmal nach 200 iterationen
Tutorien in der Wiki, mein zeug:
kephra, baumhaus, garten, gezwitscher

Es beginnt immer mit einer Entscheidung.
+8 replies

Kuerbis

2015-09-02 16:17

User since
2011-03-20
938 Artikel
BenutzerIn
[default_avatar]

Damit läuft es durch. Heißt das, dass das $i hier threadsicher ist?

Code (perl): (dl )

#!/usr/bin/env perl6
use v6;

my $n = 20;

my $result;
for ^$n { $result += $_ ** $_ }

for ^10000 {
    my @p;
    my %hash;
    for ^$n -> $i {
        push @p, Promise.start( { %hash{$i} = $i ** $i } );
    }
    await @p;
    my $sum = [+] %hash.values;
    say $sum ~ " $_";
    die $_ if $sum != $result;
}

+7 replies

Muffi

2015-09-02 16:23

User since
2012-07-18
1465 Artikel
BenutzerIn
[default_avatar]

Ich würd das nicht machen.
Du kannst "lock $var" und "unlock $var" benutzen.

Aber ungeschützt an nem Hash rumfuhrwerken würd ich mich nur traun, wenn ich wirklich weiß was Perl da intern macht.
[edit]
Lass mal folgendes passieren:
- Thread1 holt sich intern die Speicheradresse für %hash{$i}
- Danach wird Thread1 unterbrochen und Thread2 kommt dran.
- Der stellt fest, dass der Hash intern dringend mal umsortiert werden müsste.
- Danach macht er seine Arbeit
- Thread1 kommt wieder dran und hat eine veraltete Speicheradresse. Auf die schreibt er dann $i ** $i

Zu dem $i: Sieht auf den ersten Blick sicher aus, sonst gäbs wohl mehr Probleme.
Last edited: 2015-09-02 16:27:23 +0200 (CEST)

1 + 1 = 10

Kuerbis

2015-09-02 17:49
User since
2011-03-20
938 Artikel
BenutzerIn
Ursprünglich wollte ich das mit .race probieren, aber das funktioniert noch nicht ganz.
Code (perl): (dl )

1 2 3 4

#!/usr/bin/env perl6 use v6; my $files = dir( $*HOME ).race( batch => 10 );
Code: (dl )

1 2

Method 'race' not found for invocant of class 'List' in block <unit> at ./perl6.pl:4
Habe bei #perl6 gefragt: wahrscheinlich wir das mit der nächsten rakudo-Version funktionieren (falls ich alles richtig verstanden habe).
+5 replies

Kuerbis

2015-09-05 08:17

User since
2011-03-20
938 Artikel
BenutzerIn
[default_avatar]

Jetzt habe ichs nochmal mit "lock" probiert:

Code (perl): (dl )

#!/usr/bin/env perl6
use v6;

my $n = 50;
my $runs = 10000;
my $result;
for ^$n { $result += $_ ** $_ }


for ^$runs {
    my @p;
    my $sum;
    my $lock = Lock.new;
    for ^$n -> $i {
        #push @p, Promise.start( { $lock.protect( { $sum += $i ** $i } ) } );
        push @p, Promise.start( {
            my $t = $i ** $i;
            $lock.protect( { $sum += $t } );
        } );
    }
    await @p;
    say "$sum $_";
    die $_ if $sum != $result;
}

+4 replies

Kuerbis

2015-09-06 21:17

User since
2011-03-20
938 Artikel
BenutzerIn
[default_avatar]

Oder so:

Code (perl): (dl )

#!/usr/bin/env perl6
use v6;

my $n = 25_000;
my $runs = 1;
my $result;
for ^$n { $result += $_ ** $_ }
say $result;

for ^$runs {
    my $sum = [+] await map { start { $_ ** $_ } }, ^$n;
    say "$sum $_";
    die $_ if $sum != $result;
}

+3 replies

Muffi

2015-09-07 11:02

User since
2012-07-18
1465 Artikel
BenutzerIn
[default_avatar]

Gut, aber hier ist halt dann jeglicher Parallelisierungseffekt weg.

(Aber in dem speziellen Fall wohl auch in den anderen Lösungen)

1 + 1 = 10

+2 replies

Kuerbis

2015-09-07 12:12

User since
2011-03-20
938 Artikel
BenutzerIn
[default_avatar]

Code (perl): (dl )

#!/usr/bin/env perl6
use v6;

use Benchmark;

my $n = 25_000;
my $runs = 1;
my $result;

my @stats = timethis( $runs, sub {
    for ^$n { $result += $_ ** $_ }                         # ein Kern
} );
say @stats; # 1441620270 1441620539 269 269



@stats = timethis( $runs, sub {
    my $sum = [+] await map { start { $_ ** $_ } }, ^$n;    # benutzt alle 4 Kerne
    die "Error" if $sum != $result;
} );
say @stats; # 1441620539 1441620618 79 79

Muffi

2015-09-07 13:20

User since
2012-07-18
1465 Artikel
BenutzerIn

ah, ich glaub ich hatte den Code nicht kapiert
1 + 1 = 10

View all threads created 2015-09-02 12:52.