multithreading - Compartir una variable de subproceso sin hacerlo global(Perl)

scope lexical-scope

Question

Intento escribir un script simple que use threads y comparta una variable, pero no quiero hacer que esta variable sea global para todo el script. A continuación se muestra un ejemplo simplificado.

use strict;
use warnings;
use threads;
use threads::shared;

my $val:shared;

# Create threads
for my $i (1 .. 5) {
    threads->create(/&do_something, $i);
}

# Wait for all threads to complete
map { $_->join(); } threads->list();

# $val is global to the script so this line will work!
print "VAL IS: $val/n";

sub do_something {
    my $i = shift;
    print "Doing something with thread $i!/n";

    {
        lock $val;
        $val = "SOMETHING IS $i";
        print "$val/n/n";
    }
}

Salida:

¡Haciendo algo con el hilo 1! ALGO ES 1

¡Haciendo algo con el hilo 2! ALGO ES 2

¡Haciendo algo con thread 3! ALGO ES 3

¡Haciendo algo con thread 4! ALGO ES 4

¡Haciendo algo con thread 5! ALGO ES 5

VAL ES: ALGO ES 5

¿Cómo puedo obtener este efecto sin hacer que $val accesible para todo el script? En otras palabras, ¿cómo puedo hacer para intentar imprimir VAL IS: $val fallará, pero la variable aún será compartida con éxito por los hilos?

No puedo definirlo así:

# Create threads
for my $i (1 .. 5) {
    my $val:shared;
    threads->create(/&do_something, $i);
}

O obtendré:

El símbolo global "$ val" requiere un paquete explícito

¿Cuál es la forma correcta de alcanzar léxicamente una variable compartida?

Answer 1

Pase una referencia a ella como argumento.

sub do_something {
   my ($id, $lock_ref) = @_;
   print("$id: Started/n");
   {
      lock $$lock_ref;
      print("$id: Exclusive/n");
      sleep(1);
   }
   print("$id: done./n");
}

{
   my $lock :shared;
   for my $id (1..5) {
      async { do_something($id, /$lock); };
   }
}

O amplíelo para que solo los subs trabajadores puedan verlo.

{
   my $lock :shared;

   sub do_something {
      my ($id) = @_;
      print("$id: Started/n");
      {
         lock $lock;
         print("$id: Exclusive/n");
         sleep(1);
      }
      print("$id: done./n");
   }
}

for my $id (1..5) {
   async { do_something($id); };
}

Answer 2

Puede limitar el alcance de la variable compartida (asegúrese de que perl vea la variable compartida antes de la creación del hilo),

# ..
{
  my $val:shared;
  sub do_something {
      my $i = shift;
      print "Doing something with thread $i!/n";

      {
          lock $val;
          $val = "SOMETHING IS $i";
          print "$val/n/n";
      }
  }
}

# Create threads
for my $i (1 .. 5) {
    threads->create(/&do_something, $i);
}

# ...