Lang/Perl/thread の履歴(No.3)

• 履歴一覧
• 差分 を表示
• 現在との差分 を表示
• ソース を表示
• Lang/Perl/thread へ行く。
  • 1 (2020-11-14 (土) 20:57:27)
  • 2 (2020-11-21 (土) 16:52:57)
  • 3 (2023-09-14 (木) 00:52:36)

目次†

Thread†

thread の生成†

• threads を使う。

  use threads;
  
  # thread の生成
  # スレッド関数を new の第1引数に、スレッド関数に渡す引数を第2引数以降に指定する。
  my ($thread_1) = threads->new(\&thread_func, "t1");
  
  # thread 終了の待ち合わせ
  $thread_1->join;
  
  # thread 関数
  sub thread_func {
      # 処理
  }

queue による通信†

• Thread::Queue を使う。

use threads;
use Thread::Queue;

my ($queue_a) = new Thread::Queue;

# thread 生成時に、 thread 関数の引数として Queue を渡す：
my ($thread_a) = threads->new(\&thread_func_a, $queue_a);

$thread_a->join;

• Queue に積む

  $queue_a->enqueue(<データ>);

• Queue から引き抜いて $data に格納する

  $data = $queue_a->dequeue();

thread 間で共有する変数†

• thread 間で共有したい変数は、その旨明示的に宣言する必要がある。

  use threads;
  use threads::shared; # thread 間で共有するデータを扱う
  
  my <thread間共有変数> : shared = <初期化値>;

• 例

  use threads;
  use threads::shared; # thread 間で共有するデータを扱う
  
  my $data : shared = 2;
  my @datas : shared = ();