在上一篇中我們介紹了 mpi4py 中的共享文件指針 I/O 操作肴沫，下面我們將介紹 mpi4py 中 I/O 相關(guān)的 hints附较。

MPI 允許用戶為 MPI 實(shí)現(xiàn)傳遞一些 hints。對(duì) I/O 操作沪哺，這是通過(guò)一些 I/O 操作方法的 info 參數(shù)來(lái)進(jìn)行傳遞的牙瓢，這些方法包括 MPI.File.Open，MPI.File.Set_view阅羹，MPI.File.Set_info勺疼，MPI.File.Delete 等。默認(rèn)情況下捏鱼，這些方法的 info 參數(shù)都為 MPI.INFO_NULL执庐，表示用戶不傳遞任何 hints 給 MPI 實(shí)現(xiàn)。當(dāng)需要傳遞一些 hints 時(shí)穷躁，可通過(guò) MPI.Info 對(duì)象為文件指定一些如文件訪問(wèn)模式耕肩、文件系統(tǒng)相關(guān)的附加信息（即與 I/O 相關(guān)的 hints），并利用這些信息優(yōu)化 I/O 訪問(wèn)性能问潭，減少系統(tǒng)資源占用等猿诸。MPI 實(shí)現(xiàn)可以選擇忽略某些或所有用戶傳遞的 hints 而不會(huì)影響程序的正確性。需要注意的是狡忙，通過(guò) MPI.Info 對(duì)象設(shè)置的 hints 的鍵和值都是字符串梳虽。

I/O 相關(guān) hints 方法

MPI.File.Set_info(self, Info info)

通過(guò) MPI.Info 對(duì)象向 MPI 實(shí)現(xiàn)傳遞 I/O 相關(guān)的 hints。

MPI.File.Get_info(self)

獲取當(dāng)前文件正在使用的 hints灾茁，返回值是一個(gè) MPI.Info 對(duì)象窜觉。

MPI 預(yù)留的 I/O 相關(guān) hints

下表列出了 MPI 預(yù)留的 I/O 相關(guān)的 hints，這些 hints 主要影響并行文件的訪問(wèn)模式北专，指導(dǎo)文件在 I/O 設(shè)備上的布局禀挫。

不同的 MPI 實(shí)現(xiàn)可能還有額外的 hints，用戶應(yīng)該查閱其相關(guān)文檔以了解其可用的 hints 及這些 hints 的作用滨达。

例程

下面給出使用例程奶稠。

# io_hints.py

"""
Demonstrates how to pass I/O related hints to the implementation.

Run this with 4 processes like:
$ mpiexec -n 4 python io_hints.py
"""

import numpy as np
from mpi4py import MPI


comm = MPI.COMM_WORLD
rank = comm.Get_rank()

buf = np.full((5,), rank, dtype='i')

filename = 'temp.txt'

# create a MPI.Info object
info = MPI.Info.Create()
# set some MPI predefined hints
# number of I/O devices across which the file should be striped
info['striping_factor'] = '16'
# the striping unit in bytes
info['striping_unit'] = '1048576'
# buffer size for collective I/O
info['cb_buffer_size'] = '8388608'
# number of processes that should perform disk accesses during collective I/O
info['cb_nodes'] = '%d' % comm.size
# set some additional hints supported by ROMIO
# buffer size for data sieving in independent reads
info['ind_rd_buffer_size'] = '2097152'
# buffer size for data sieving in independent writes
info['ind_wr_buffer_size'] = '1048576'

# open the file for read and write, create it if it does not exist,
# and delete it on close, with the info object defined above
fh = MPI.File.Open(comm, filename, amode= MPI.MODE_CREATE | MPI.MODE_RDWR | MPI.MODE_DELETE_ON_CLOSE, info=info)

# free the info object
info.Free()

# get the currently used hints
info_used = fh.Get_info()
if rank == 0:
    for k in info_used:
        print '%s: %s' % (k, info_used[k])

# close the file
fh.Close()

運(yùn)行結(jié)果如下：

$ mpiexec -n 4 python io_hints.py
cb_buffer_size: 8388608
romio_cb_read: automatic
romio_cb_write: automatic
cb_nodes: 1
romio_no_indep_rw: false
romio_cb_pfr: disable
romio_cb_fr_types: aar
romio_cb_fr_alignment: 1
romio_cb_ds_threshold: 0
romio_cb_alltoall: automatic
ind_rd_buffer_size: 2097152
ind_wr_buffer_size: 1048576
romio_ds_read: automatic
romio_ds_write: automatic
striping_unit: 1048576
cb_config_list: *:1

以上介紹了 mpi4py 中 I/O 相關(guān)的 hints，在下一篇中我們將介紹 mpi4py 中 I/O 操作的一致性語(yǔ)義捡遍。