跳到主要内容
版本：1.2.2

LineProcMirror

类私有上下文源码

pbuf: syncstream.LineProcBuffer
buffer = pbuf.mirror

with buffer:
    ...

进程安全缓存的镜像。

危险

该mirror由LineProcBuffer初始化，且用于管理要写入到buffer的行数据。用户不需要、也不应使用该类来实例化对象。请总是使用pbuf.mirror来获取mirror对象。

别名​

该类可以按以下方式之一获取

import syncstream


syncstream.LineProcMirror
syncstream.mproc.LineProcMirror

参数​

参数类型必选
说明
q_maxsizeint队列的最大长度。该值和queue.qsize意义相同。
aggressivebool若设为True，则启用积极模式，亦即是说，只要有新的数据写入该 mirror，就会立即传递给缓存。若设为False，则只会在新写一整行的时候、才传递给缓存。
timeoutint | None网络同步事件的时限。该值和queue.put(timeout)的参数意义一致。
_queueQueue | None用来与缓存通信的队列。该对象是一个multiprocessing.Queue()、或由multiprocessing.Manager()给出。队列对象由LineProcBuffer构造。
_statedict[str, Any] | None由multiprocessing.Manager()给出的共享状态字典。该字典对象由 LineProcBuffer构造。
_state_lockLock | None状态字典的读/写锁。由multiprocessing.Manager()给出。该锁对象由LineProcBuffer构造。

方法​

close​

buffer.close(exc: BaseException | None = None)

关闭 IO。该方法只会生效一次。第二次调用则无任何效果。

输入​

参数类型必选
说明
excBaseException若exc非None，则在关闭缓存前调用send_error()。否则，调用send_eof()。

clear​

buffer.clear()

清空临时缓存。

该方法会清空mirror的临时缓存。若mirror按aggresive模式工作，则临时缓存不会用到。在此情形下，该方法将不会对mirror产生任何影响。

该方法是线程安全的。且不同进程的镜像并不会共享相同的临时缓存。且需要注意的是，该方法不会清空共享队列的内容。

new_line​

buffer.new_line()

清空当前的临时缓存，并人为地触发一个“新行”信号。若当前的临时缓存包含数据，则会先将数据移动到存储区，然后再创建新行。若当前的临时缓存的已经是新行，则不做任何处理。

该方法等价于

if buffer.last_line.tell() > 0:
    write('\n')

flush​

buffer.flush()

刷新当前正在写入行的数据流（临时缓存）。

send_eof​

buffer.send_eof()

发送安全关闭信号。

应当在子进程的结尾使用该信号。该方法用来通知缓存子进程的工作已经安全完成。

危险
  • 在每个子进程的结尾，应当总是使用send_eof()或send_error()。否则，主线程（的缓存）有可能造成死锁。
  • 在每个子进程的结尾，应当只使用一次send_eof()或send_error()。例如，若调用过send_error()，则不应再调用send_eof()。从同一子进程发送超过一个关闭信号，可能引发严重故障。

send_error​

buffer.send_error(error: BaseException)

向主缓存发送异常对象。

发送缓存过的异常对象。该方法需要用于try / except块中。错误对象将会在主缓存中捕获为一条信息。

危险

参见send_eof()。

输入​

参数类型必选
说明
errorBaseException要发送的异常对象。

send_warning​

buffer.send_warning(warning: Warning)

向主缓存发送标准警告对象。

发送缓存过的警告对象。建议在每当需要写入警告日志时、使用该方法。警告对象将会在主缓存中捕获为一条信息。

警告

该方法只能捕获标准库定义的警告对象。某些不同的警告对象，例如logging.warning所写的warning信息，则无法被该方法收集。

输入​

参数类型必选
说明
warningWarning要发送的警告对象。

send_data​

buffer.send_data(data: str)

向主缓存发送数据。

该方法等价于在进程安全的保护机制下、同步地调用主缓存（LineProcBuffer）的以下方法：

super(LineProcBuffer, pbuf).write(data)

该方法被其他方法隐式调用，故用户不应使用该方法。

输入​

参数类型必选
说明
datastr要发送到主缓存的str。

read​

line: str = buffer.read(size: int | None = None)

该方法只会读取、当前保留在mirror的临时缓存内的数据。若属性aggressive为True，则read()方法将总是返回空值。

输入​

参数类型必选
说明
sizeint若设为None，则会返回整个存储区。若设为一个整数，则会返回最后size条信息。

输出​

参数类型
说明
linestr当前mirror的临时存储结果。在临时存储内的数据还没有发送到主缓存。

write​

n_bytes: int = buffer.write(data: str)

写缓存的方法。源数据的形式与文字IO的数据形式相同。若属性aggressive为True，每次调用write()时，都将会使得流内的数据发送到主缓存。否则，只在每当data包含断行符的时候、才会将流的数据发送到主缓存。

该方法是线程安全的。

输入​

参数类型必选
说明
datastr要写入的信息。会自动检测其中包含的断行符。

输出​

参数类型
说明
n_bytesint所要写入缓存的byte数目。该值直接从输入data计算。

fileno​

buffer.fileno() -> Never

返回文件 ID。

由于该缓存不使用文件 ID，故而该方法会抛出OSError。

isatty​

is_atty: False = buffer.fileno()

流是否连接到了终端/TTY 上。返回False。

输出​

参数类型
说明
is_attybool恒为False.

readable​

is_readable: bool = buffer.readable()

流是否可读。只要流还未关闭，其就是可读的。

若流不再可读，调用read()会抛出OSError。

输出​

参数类型
说明
is_readablebool若缓存未关闭，返回True。否则，返回False。

writable​

is_writable: bool = buffer.writable()

流是否可写。只要流还未关闭，其就是可读的。

若流不再可写，调用read()会抛出OSError。

输出​

参数类型
说明
is_writablebool若缓存未关闭，返回True。否则，返回False。

seekable​

is_seekable: False = buffer.seekable()

流是否支持随机访问。该缓存不支持。

输出​

参数类型
说明
is_seekablebool恒为False。

seek​

buffer.seek() -> Never

由于缓存不支持随机访问，调用该方法会抛出OSError。

属性​

aggressive​

is_aggressive: bool = buffer.aggressive

积极模式。

该模式只能在初始化的时候设置。若设为True，则积极模式启用，mirror将会在每当收到新的数据时，将信息传递给主缓存。若设为False，则只会在新写一整行的时候、才传递给缓存。

timeout​

tiemout: int = buffer.timeout

设置给队列的时限。该值和queue.put(timeout)的参数意义一致。

在当前实现中，该值总是设置为None，但用户使用mirror时，可以修改该值。

closed​

is_closed: bool = buffer.closed

检查缓存是否已经被关闭。

范例​

参见LineProcBuffer。