Method Prefetch

mlx/data/stream/Prefetch.cpp:9–19

namespace stream {

Prefetch::Prefetch(
    const std::shared_ptr<Stream>& stream,
    int prefetch_size,
    int num_thread)
    : stream_(stream),
      pool_(std::make_shared<core::ThreadPool>(num_thread)),
      prefetchSize_(prefetch_size) {
  if (prefetchSize_ < 0) {
    throw std::runtime_error("Prefetch: prefetch size must be positive");
  }
}

Prefetch::~Prefetch() {
  std::unique_lock lock(mutex_);