mxnet

MxNet源码解析(5) io

2018-09-14  本文已影响0人  Junr_0926

1. 前言

数据的读取很大程度上决定了代码运行的快慢。
先从python端的data io开始。在MXNet的python文件夹中,io.py定义了io需要的函数,其中_init_to_moduel会在我们import该包的时候运行,它的函数体如下:

def _init_io_module():
    """List and add all the data iterators to current module."""
    plist = ctypes.POINTER(ctypes.c_void_p)()
    size = ctypes.c_uint()
    check_call(_LIB.MXListDataIters(ctypes.byref(size), ctypes.byref(plist))) # 查看一共注册了多少个迭代器
    module_obj = sys.modules[__name__]
    for i in range(size.value):
        hdl = ctypes.c_void_p(plist[i])
        dataiter = _make_io_iterator(hdl)
        setattr(module_obj, dataiter.__name__, dataiter) # 将迭代器注册到包名下

该函数会将注册的迭代器都在io的名字空间下注册。注册之前,会使用MXDataIter进行包装,也就是说当我们在调用例如ImageRecordIter的方法的时候,其实调用的是MXDataIter的方法。
在初始化的时候,会调用Init方法,在调用next的时候,会调用对应的Next方法,在调用reset的时候会调用BeforeFirst

2. data.h

定义了迭代器的接口。

3. io.h

MXnet中的迭代器

4. augmenter

MXNet中定义了数据增强的迭代器,在源码中主要定义了两个增强的方法,一个是image_aug_default.cc,一个image_det_aug_default

4.1 image_aug_default.cc

template<typename DType>
  inline parameter::FieldEntry<DType>& DECLARE(
      parameter::ParamManagerSingleton<PType> *manager,
      const std::string &key, DType &ref) { // NOLINT(*)
    parameter::FieldEntry<DType> *e =
        new parameter::FieldEntry<DType>();
    e->Init(key, this->head(), ref);
    manager->manager.AddEntry(key, e);
    return *e;
  }

5. iter_image_recordio.cc

5.1 Init

初始化函数会首先初始化未定义的参数,然后使用参数初始化parser_。接着会初始化iter_,它的定义:dmlc::ThreadIter<std::vector<InstVector<DType>> > iter_;

6. inst_vector.h

TensorVector:由一组Tensor组成的vector,支持不同shape

InstVector:由一组(label, example)组成的列表

7. threaditer.h

定义了类:ThreadedIter,在该类的内部定义了内部类:Producer

8. im2rec

上一篇下一篇

猜你喜欢

热点阅读