zoukankan      html  css  js  c++  java
  • Python

    Timer starts its work after a delay and can be canceled at any point within that delay time period.

    Threading


    Python includes sophisticated tools for managing concurrent operations using processes and threads. Even many relatively simple programs can be made to run faster by applying techniques for running parts of the job concurrently using these modules.

    subprocess provides an API for creating and communicating with secondary processes. It is especially good for running programs that produce or consume text, since the API supports passing data back and forth through the standard input and output channels of the new process.

    The signal module exposes the UNIX signal mechanism for sending events to other processes. The signals are processed asynchronously, usually by interrupting what the program is doing when the signal arrives. Signalling is useful as a coarse messaging system, but other inter-process communication techniques are more reliable and can deliver more complicated messages.

    threading includes a high-level, object-oriented API for working with concurrency from Python. Thread objects run concurrently within the same process and share memory. Using threads is an easy way to scale for tasks that are more I/O bound than CPU bound.

    The multiprocessing module mirrors threading, except that instead of a Thread class it provides a Process. Each Process is a true system process without shared memory, but multiprocessing provides features for sharing data and passing messages between them. In many cases, converting from threads to processes is as simple as changing a few import statements.

    import threading
    import time
    import logging
    
    logging.basicConfig(level=logging.DEBUG,
        format='(%(threadName)-10s) %(message)s',
    )
    
    def worker():
        while 1:
            time.sleep(3)
            logging.debug('worker running')
    
    threads = []
    for i in range(2):
        
        # t = threading.Thread(target=worker)
        t = threading.Timer(1, worker)
        threads.append(t)
        t.start()
        logging.debug('loop running')

    将threading.Thread对象改为Timer,构造对象的参数也改为相应的(延迟时间, 函数名).

    比较重要的是绿色背景的代码,这个是用于调试。这也提醒了我,线程是进程的一个“逻辑”分支。

    调试信息如下:

    (MainThread) loop running
    (MainThread) loop running
    (Thread-2  ) worker running
    (Thread-1  ) worker running
    (Thread-1  ) worker running
    (Thread-2  ) worker running
    (Thread-2  ) worker running
    (Thread-1  ) worker running
    (Thread-1  ) worker running
    (Thread-2  ) worker running
    

      

    以下是我自己用画图的理解:

  • 相关阅读:
    基本类型和包装类对象使用 == 和 equals进行比较的结果?
    ==和equals的区别是什么?
    JDK和JRE有什么区别?
    Java自学指南三、入门视频优先
    Java自学指南二、后端开发全景图与快速入门
    Java自学指南一、找一个开始并能坚持下去的理由
    什么是 happens-before 原则?
    什么是 Java 内存模型?
    Java 中有哪些无锁技术来解决并发问题?如何使用?
    什么是活锁和饥饿?
  • 原文地址:https://www.cnblogs.com/dotdog/p/4599492.html
Copyright © 2011-2022 走看看