perl 线程（2）

perl 线程（2）发布时间：2020-12-16 00:34:45  所属栏目：大数据  来源：网络整理 
导读：=========================threads=========================== #!/usr/bin/perl use ? threads ( 'yield' , ???????????? 'stack_size' ? = 64*4096, 'exit' ? =? 'threads_only' 'stringify' ); ? sub ? start_thread { ??? my ? @args ? =? @_ ; ??? prin

 <<=========================threads===========================>>
 
 #!/usr/bin/perl
 
 use?threads ('yield',
 
 ????????????'stack_size'?=> 64*4096,
 
'exit'?=>?'threads_only''stringify');
 
 ? 
      
sub?start_thread {
 
???my?@args?=?@_;
 
???print('Thread started: 'join' '@args),?"n" }
 
 ? 
      
 ##创建线程的方法
 
# my $thr = threads->create('func_name',...);
 
# my $thr = threads->create(sub { ... },...);
 
# my $thr = threads->create(&;func,0)!important"># The "->new()" method is an alias for "->create()".
 
$thr?= threads->create('start_thread''argument1''argument2');?????#通过create创建线程。返回线程实例
 
 $thr->();????????????????#等待线程结束
 
threads->create({?"I am a threadn"); })->();???????????????????#创建一个线程，没有返回值。那这个线程实例如何访问呢？
 
$thr2?= async {?foreach?(@ARGS) {?print"$_n"; } };??????????????????????????????#通过async使用匿名子例程创建线程
 
$thr2();
 
if?($err?->error()) {
 
warn"Thread error: $errn");
 
}
 
# 在隐式的列表环境中调用thread
 
$thr3?= threads->create({?return?(qw/a b c/); });
 
# 在显式的列表环境中调用thread
 
$thr4?= threads->create({'context'?'list'},monospace!important; font-style:normal!important; font-size:1em!important; min-height:inherit!important">?????????????????????????(qw/a b c/); });
 
# 由于创建线程时使用的子例程返回的是列表，所以这里的join函数返回的也是列表
 
@results?$thr3();
 
 print?"@resultsn"# 把线程从主线程中分离出来
 
# $thr->detach();??????? ##报错：Cannot detach a joined thread,因为$thr已经调用过join()
 
$thr4->detach();?????##
 
$tid?->tid();
 
"线程4ID：$tidn";
 
# Get a thread's object
 
$thr6?= threads->self();
 
$thr7?= threads->object($tid# Get a thread's ID
 
= threads->tid();
 
=?"$thr7";?????#根据线程实例获得线程ID
 
# 给其他线程一个运行的机会
 
threads->yield();
 
yield();
 
# 返回未分离的线程列表
 
@threads?= threads->list();
 
$thread_count?= threads->list();
 
@running?= threads->list(threads::running);
 
@joinable?= threads->list(threads::joinable);
 
# 判断两个线程是相同
 
==?) {
 
"thread4 equals to thread2.n"# 管理线程栈大小
 
$stack_size?= threads->get_stack_size();
 
$old_size?= threads->set_stack_size(32*4096);
 
# Create a thread with a specific context and stack size
 
$thr5?= threads->create({?'context'???????????????????????????????=> 32*4096,monospace!important; font-style:normal!important; font-size:1em!important; min-height:inherit!important; color:blue!important">'exit'???????'thread_only'??????????????????????????&;start_thread);
 
# Get thread's context
 
$wantarray?->wantarrayprint?$wantarray# Check thread's state
 
$thr5->is_running()) {
 
sleep(1);
 
->is_joinable()) {
 
???# Send a signal to a thread
 
kill'SIGUSR1'# Exit a thread
 
threads->exit();????????????????????????????????????

给变量加锁，直到锁超出范围。?给变量加锁只影响到lock函数的调用--即一个线程lock var1后，另一个线程再调用lovk var1时线程就会阻塞，但?lock ?VARIABLE并不影响正常的对变量的访问。

如果锁往的是一个容器（如哈希或数组），那么其中的每一个元素并没有全部被锁住。比如一个线程中调用lock ?@arr，在另一个线程中调用lock $arr[3]时并不会阻塞。

async函数创建并返回一个线程实例，该线程要执行的代码全在BLOCK中，这里BLOCK是个匿名子例程，所以其后一定加分号。

上面3个函数主要用于线程问同步，都以一个已加锁的变量作为输入参数。当一个线程调用cond_wait后阻塞自己；当一个线程发出cond_broadcast后所有阻塞的线程得救；当一个线程发出?cond_signal后只有一个阻塞的线程得救，至于是哪一个由系统内部决定。当然只有?LOCKED_VARIALBLE参数相同时才为一组，大家才可以在一起玩同步。

把CPU控制权交给另外一个线程，至于是哪个线程依赖于当时的运行环境。

下面这3个函数在5005threads中还可以用，但是在ithreads中已经不可用了。

默认下数据都是线程私有的，新创建的线程获得已有变量的一份私有拷贝。?threads::shared用于在线程之间共享数据结构，可共享的数据类型只有6种，标量数据、数组、散列、以及它们的引用。

# Object status (i.e.,the class an object is blessed into) is also ?cloned.? ? ? ? ? ?

判断变量是否为共享变量，如果是则返回变量的内部ID（类似于refaddr函数），如果不是返回undef。

如果is_shared参数是数组或散列，它并不检查容器中的元素是否为共享变量。如下

当有其他线程signal第一个参数变量CONDVAR时，第二个参数变量LOCKVAR被解锁。

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!