ZetCode

Python flush 函数

最后修改时间：2025 年 3 月 26 日

本综合指南将介绍 Python 的 flush 函数，它强制将缓冲数据立即写入磁盘。我们将涵盖其目的、何时使用它，以及演示其在文件操作和输出缓冲场景中重要性的实际示例。

基本定义

flush 方法强制内部缓冲区立即将数据写入磁盘。文件操作通常为了提高性能而进行缓冲，这意味着数据不会立即写入。flush 可确保数据在需要时被物理写入。

缓冲通过减少磁盘 I/O 操作来提高性能。但是，在某些情况下需要立即写入，例如记录关键事件或当另一个进程需要立即读取数据时。

flush 方法可用于文件对象、stdout 和其他流对象。它不会关闭文件，但会确保所有缓冲数据都被写入底层存储。

基本文件刷新

此示例演示了 flush 的基本用法，以确保数据立即写入磁盘。没有刷新，数据可能会保留在缓冲区中。

basic_flush.py 
# Writing to a file with explicit flushing
file = open('output.txt', 'w')
file.write('This data might be buffered\n')
file.flush()  # Force write to disk
print("Data has been flushed to disk")
file.close()

在此示例中，我们将数据写入文件并立即调用 flush 以确保其写入磁盘。如果没有此调用，数据可能会保留在内存缓冲区中，直到文件关闭或缓冲区填满为止。

这对于必须立即持久化的关键数据尤其重要，例如事务日志或系统状态更新。flush 调用提供了数据已被物理存储的保证。

刷新标准输出

flush 方法也可用于 sys.stdout，当您需要确保输出立即出现在控制台或管道中时，这非常有用。

stdout_flush.py 
import sys
import time

print("This appears immediately", flush=True)
print("This might be buffered")

for i in range(5):
    print(f"Progress: {i+1}/5", end='\r')
    time.sleep(1)
print("\nDone", flush=True)

此示例显示了刷新 stdout 的两种方法：使用 print 中的 flush 参数和调用 sys.stdout.flush()。进度计数器演示了实时更新为何需要刷新。

没有刷新，进度更新可能直到循环完成后才显示。刷新可确保每个更新立即可见，从而创建平滑的进度指示器。

在日志系统中刷新

日志系统通常为了提高性能而使用缓冲。本示例演示了在发生关键事件时如何确保日志条目立即写入。

logging_flush.py 
import logging

# Configure basic logging
logging.basicConfig(
    filename='app.log',
    level=logging.INFO,
    format='%(asctime)s - %(message)s'
)

def log_critical_event(message):
    logging.info(message)
    logging.getLogger().handlers[0].flush()
    print(f"Logged: {message}", flush=True)

log_critical_event("System started")
log_critical_event("Critical error detected!")

此示例演示了为关键事件刷新日志文件和 stdout。处理程序的 flush 方法可确保日志条目立即写入磁盘，而不仅仅是存储在内存缓冲区中。

在生产系统中，此技术对于调试崩溃或监控关键系统非常宝贵，这些系统需要立即持久化日志条目。

使用上下文管理器刷新

虽然上下文管理器会自动关闭文件，但您可能仍需要在上下文结束之前刷新数据。此示例显示了如何同时完成这两项操作。

context_flush.py 
# Using flush within a context manager
with open('data.txt', 'w') as file:
    file.write('Initial data\n')
    file.flush()  # Ensure data is written before continuing
    
    # Simulate some processing
    import time
    time.sleep(2)
    
    file.write('Additional data\n')
    # No explicit flush needed - context manager will handle it

此示例显示了在上下文管理器中进行刷新，以确保数据在特定点写入，同时仍受益于自动关闭。第一次写入被立即刷新，而第二次写入依赖于上下文管理器。

这种模式在分阶段写入数据时非常有用，此时中间结果应在继续进行可能存在风险的操作之前持久化。

在网络操作中刷新

网络套接字和管道也使用缓冲。此示例演示了在写入网络套接字时刷新，以确保数据立即发送。

network_flush.py 
import socket

def send_immediate_message(host, port, message):
    with socket.create_connection((host, port)) as sock:
        sock.sendall(message.encode('utf-8'))
        sock.send(b'\x04')  # End-of-transmission
        sock.flush()  # Ensure all data is sent
        print("Message sent and flushed", flush=True)

# Example usage (would need a server to actually work)
# send_immediate_message('localhost', 9000, 'Urgent update')

此示例显示了刷新网络套接字以确保所有缓冲数据立即发送。网络协议通常需要及时传递消息，这使得 flush 对于正确通信至关重要。

没有刷新，小消息可能会被延迟，因为系统等待更多数据来高效地填充数据包。当即时传递比网络效率更重要时，刷新会覆盖此优化。

最佳实践

资料来源

作者

我叫 Jan Bodnar，是一名充满激情的程序员，拥有丰富的编程经验。我自 2007 年以来一直在撰写编程文章。至今，我已撰写了 1,400 多篇文章和 8 本电子书。我在教授编程方面拥有十多年的经验。

列出所有 Python 教程。