cuda_stream.hpp

前往此文件的文档。

/*
 * Copyright (c) 2020-2024, NVIDIA CORPORATION.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * https://apache.ac.cn/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#pragma once

#include <rmm/cuda_stream_view.hpp>
#include <rmm/detail/error.hpp>
#include <rmm/detail/export.hpp>
#include <rmm/detail/logging_assert.hpp>

#include <cuda_runtime_api.h>

#include <functional>
#include <memory>

namespace RMM_NAMESPACE {
class cuda_stream {
 public
 cuda_stream(cuda_stream&&) = default;
 cuda_stream& operator=(cuda_stream&&) = default;
 ~cuda_stream() = default;
 cuda_stream(cuda_stream const&) = delete; // Copying disallowed: one stream one owner
 cuda_stream& operator=(cuda_stream&) = delete;

 cuda_stream()
 : stream_{[]() {
 auto* stream = new cudaStream_t; // NOLINT(cppcoreguidelines-owning-memory)
 RMM_CUDA_TRY(cudaStreamCreate(stream));
 return stream;
 }(),
 [](cudaStream_t* stream) {
 RMM_ASSERT_CUDA_SUCCESS(cudaStreamDestroy(*stream));
 delete stream; // NOLINT(cppcoreguidelines-owning-memory)
 }}
 {
 }

 [[nodiscard]] bool is_valid() const { return stream_ != nullptr; }

 [[nodiscard]] cudaStream_t value() const
 {
 RMM_LOGGING_ASSERT(is_valid());
 return *stream_;
 }

 explicit operator cudaStream_t() const noexcept { return value(); }

 [[nodiscard]] cuda_stream_view view() const { return cuda_stream_view{value()}; }

 operator cuda_stream_view() const { return view(); }

 void synchronize() const { RMM_CUDA_TRY(cudaStreamSynchronize(value())); }

 void synchronize_no_throw() const noexcept
 {
 RMM_ASSERT_CUDA_SUCCESS(cudaStreamSynchronize(value()));
 }

 private
 std::unique_ptr<cudaStream_t, std::function<void(cudaStream_t*)>> stream_;
};
 // end of group
} // namespace RMM_NAMESPACE