Python's queue module provides thread-safe queues, suitable for multi-thread data delivery; 2. Queue() is a FIFO queue, LifoQueue() is a last-in first-out queue, and PriorityQueue() is dequeued according to priority; 3. In multi-thread, put() is enqueued and get() is dequeued, and task_done() and join() are used to ensure the completion of the task; 4. The producer-consumer model is a typical application, and the consumer needs to be notified to end with None signal. The program exits correctly after all tasks are completed.
queue
module in Python provides thread-safe queue implementations, which are often used to safely pass data in multi-threaded programming. Below is a simple and practical example of using queue
to help you quickly understand its basic usage.

1. Basic Queue (FIFO queue)
import queue # Create a first-in-first-out queue q = queue.Queue() # Add elements (join) q.put("Task1") q.put("Task 2") q.put("Task 3") # Get elements (dequeue) while not q.empty(): item = q.get() print(f"processing: {item}") q.task_done() # means that the task has been completed (it is important in the thread)
Output:
Processing: Task 1 Processing: Task 2 Processing: Task 3
Queue()
is FIFO (first in, first out) by default, suitable for most scenarios.
2. LIFO queue (similar to stack)
import queue q = queue.LifoQueue() # Last in first out q.put("Task 1") q.put("Task 2") q.put("Task 3") while not q.empty(): item = q.get() print(f"processing: {item}") q.task_done()
Output:
Processing: Task 3 Processing: Task 2 Processing: Task 1
LifoQueue
can be used to simulate stack structures, such as undo operations, recursive substitution, etc.
3. Priority Queue
import queue q = queue.PriorityQueue() # Add task in format (priority, data) # The smaller the number, the higher the priority q.put((3, "Low Priority Task")) q.put((1, "High priority task")) q.put((2, "Medium Priority Task")) while not q.empty(): priority, task = q.get() print(f"processing priority {priority}: {task}") q.task_done()
Output:
Processing priority 1: High priority task processing priority 2: Medium priority task processing priority 3: Low priority task
Commonly used in task scheduling systems, such as job queuing, event processing, etc.
4. Use Queue in multithreading (producer-consumer model)
import queue import threading import time def producer(q): for i in range(5): q.put(f"task-{i}") print(f"Production: Task-{i}") time.sleep(0.5) def consumer(q): While True: item = q.get() if item is None: break print(f"Consumption: {item}") time.sleep(1) q.task_done() # Create queue q = queue.Queue() # Create thread t1 = threading.Thread(target=producer, args=(q,)) t2 = threading.Thread(target=consumer, args=(q,)) t1.start() t2.start() t1.join() # Wait for the producer to complete# Send the end signal q.put(None) # Notify the consumer to end t2.join() # Wait for the consumer to complete print("All tasks are completed")
This is the most typical use of
queue
: communication between threads , avoiding race conditions.
Tips
-
q.put(item)
: join the queue, optional parametersblock=True, timeout=None
-
q.get()
: dequeue, also supports blocking and timeout -
q.task_done()
: Must be called after processing the task -
q.join()
: Block until all tasks in the queue are processed bytask_done()
-
q.empty()
andq.full()
are not thread-safe and are for reference only
Basically that's it. queue
module is simple but powerful, especially suitable for multithreaded task scheduling. Not complicated, but it is easy to ignore the combination of task_done()
and join()
.
The above is the detailed content of python queue example. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undress AI Tool
Undress images for free

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics

First, use JavaScript to obtain the user system preferences and locally stored theme settings, and initialize the page theme; 1. The HTML structure contains a button to trigger topic switching; 2. CSS uses: root to define bright theme variables, .dark-mode class defines dark theme variables, and applies these variables through var(); 3. JavaScript detects prefers-color-scheme and reads localStorage to determine the initial theme; 4. Switch the dark-mode class on the html element when clicking the button, and saves the current state to localStorage; 5. All color changes are accompanied by 0.3 seconds transition animation to enhance the user

Yes, a common CSS drop-down menu can be implemented through pure HTML and CSS without JavaScript. 1. Use nested ul and li to build a menu structure; 2. Use the:hover pseudo-class to control the display and hiding of pull-down content; 3. Set position:relative for parent li, and the submenu is positioned using position:absolute; 4. The submenu defaults to display:none, which becomes display:block when hovered; 5. Multi-level pull-down can be achieved through nesting, combined with transition, and add fade-in animations, and adapted to mobile terminals with media queries. The entire solution is simple and does not require JavaScript support, which is suitable for large

The settings.json file is located in the user-level or workspace-level path and is used to customize VSCode settings. 1. User-level path: Windows is C:\Users\\AppData\Roaming\Code\User\settings.json, macOS is /Users//Library/ApplicationSupport/Code/User/settings.json, Linux is /home//.config/Code/User/settings.json; 2. Workspace-level path: .vscode/settings in the project root directory

Full screen layout can be achieved using Flexbox or Grid. The core is to make the minimum height of the page the viewport height (min-height:100vh); 2. Use flex:1 or grid-template-rows:auto1frauto to make the content area occupy the remaining space; 3. Set box-sizing:border-box to ensure that the margin does not exceed the container; 4. Optimize the mobile experience with responsive media query; this solution is compatible with good structure and is suitable for login pages, dashboards and other scenarios, and finally realizes a full screen page layout with vertical centering and full viewport.

Selecting the Java SpringBoot React technology stack can build stable and efficient full-stack web applications, suitable for small and medium-sized to large enterprise-level systems. 2. The backend uses SpringBoot to quickly build RESTfulAPI. The core components include SpringWeb, SpringDataJPA, SpringSecurity, Lombok and Swagger. The front-end separation is achieved through @RestController returning JSON data. 3. The front-end uses React (in conjunction with Vite or CreateReactApp) to develop a responsive interface, uses Axios to call the back-end API, and ReactRouter

Use performance analysis tools to locate bottlenecks, use VisualVM or JProfiler in the development and testing stage, and give priority to Async-Profiler in the production environment; 2. Reduce object creation, reuse objects, use StringBuilder to replace string splicing, and select appropriate GC strategies; 3. Optimize collection usage, select and preset initial capacity according to the scene; 4. Optimize concurrency, use concurrent collections, reduce lock granularity, and set thread pool reasonably; 5. Tune JVM parameters, set reasonable heap size and low-latency garbage collector and enable GC logs; 6. Avoid reflection at the code level, replace wrapper classes with basic types, delay initialization, and use final and static; 7. Continuous performance testing and monitoring, combined with JMH

To correctly handle JDBC transactions, you must first turn off the automatic commit mode, then perform multiple operations, and finally commit or rollback according to the results; 1. Call conn.setAutoCommit(false) to start the transaction; 2. Execute multiple SQL operations, such as INSERT and UPDATE; 3. Call conn.commit() if all operations are successful, and call conn.rollback() if an exception occurs to ensure data consistency; at the same time, try-with-resources should be used to manage resources, properly handle exceptions and close connections to avoid connection leakage; in addition, it is recommended to use connection pools and set save points to achieve partial rollback, and keep transactions as short as possible to improve performance.

JavaFlightRecorder(JFR)andJavaMissionControl(JMC)providedeep,low-overheadinsightsintoJavaapplicationperformance.1.JFRcollectsruntimedatalikeGCbehavior,threadactivity,CPUusage,andcustomeventswithlessthan2%overhead,writingittoa.jfrfile.2.EnableJFRatsta
