# Non-blocking request
$ua->get('mojolicious.org' => sub ($ua, $tx) { say $tx->result->dom->at('title')->text });
Mojo::IOLoop->start unless Mojo::IOLoop->is_running;
复制代码

my $wdir = "D:/blah";
for my $city ( keys %list )
{
    my $name = sprintf "%s/%s.json", $wdir, gbk($city);
    $query->{"toCountryId"} = $ct_code->{$city};  # 城市ID 更新到请求数据中
    $res = $ua->post( $url, to_json( $query ), closure->( $name ) );
}

$loop->start unless $loop->is_running;

sub closure ($file) {
    return sub ($ua, $tx) {
        printf "%s\n", $file;
        write_file( $file, $tx->result->body );
    }
}
复制代码

import threading
import time


def fun(event_lock, tips):
    while True:
        event_lock.wait()
        print(tips)
        time.sleep(1)
        


if __name__ == "__main__":
    event_lock = threading.Event()
    event_lock.set()
    t1 = threading.Thread(target = fun, args = (event_lock, "线程 1"), daemon = True)
    t2 = threading.Thread(target = fun, args = (event_lock, "线程 2"), daemon = True)
    
    t1.start()
    t2.start()
    
    input_str = ''
    while True:
        input_str = input("1: 暂定线程 2: 开始线程")
        if input_str == "1":
            event_lock.clear()
        elif input_str == "2":
            event_lock.set()
    t1.join()
复制代码

using System;
using System.Threading;
 
class Test
{
    static void Main()
    {
        int PoolSize = Environment.ProcessorCount; // 获取当前计算机上的处理器数。
         
        EventWaitHandle ewh = new EventWaitHandle(false, EventResetMode.ManualReset); // 事件锁
        
        Thread[] ThreadPool = new Thread[PoolSize];
         
        for (sbyte i=0; i<PoolSize; i++)
        {
            ThreadPool[i] = new Thread(Occupy);
            ThreadPool[i].IsBackground = true;
        }
        for (sbyte i=0; i<PoolSize; i++)
            ThreadPool[i].Start(ewh);
         
        while (true)
        {
            Console.Write("1 占用cpu资源\n2 释放cpu资源\n");
            string input = Console.ReadLine();
            if (input == "1")
            {
                ewh.Set();
            }
            else if (input == "2")
            {
                ewh.Reset();
            }
        }
    }
     
    static void Occupy(object EventLock)
    {
        EventWaitHandle el = EventLock as EventWaitHandle;
        while (true)
        {
            el.WaitOne();
        }
    }
 
}
复制代码