tvm
parallel_for.h
Go to the documentation of this file.
1 /*
2  * Licensed to the Apache Software Foundation (ASF) under one
3  * or more contributor license agreements. See the NOTICE file
4  * distributed with this work for additional information
5  * regarding copyright ownership. The ASF licenses this file
6  * to you under the Apache License, Version 2.0 (the
7  * "License"); you may not use this file except in compliance
8  * with the License. You may obtain a copy of the License at
9  *
10  * http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing,
13  * software distributed under the License is distributed on an
14  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15  * KIND, either express or implied. See the License for the
16  * specific language governing permissions and limitations
17  * under the License.
18  */
19 
24 #ifndef TVM_SUPPORT_PARALLEL_FOR_H_
25 #define TVM_SUPPORT_PARALLEL_FOR_H_
26 
28 
29 #include <functional>
30 #include <vector>
31 
32 namespace tvm {
33 namespace support {
34 
35 using PartitionerFuncType = std::function<std::vector<std::vector<int>>(int, int, int, int)>;
36 
46 TVM_DLL std::vector<std::vector<int>> rr_partitioner(int begin, int end, int step, int num_threads);
47 
67 TVM_DLL void parallel_for(int begin, int end, const std::function<void(int)>& f, int step = 1,
68  const PartitionerFuncType partitioner = rr_partitioner);
69 
88 TVM_DLL void parallel_for_dynamic(int begin, int end, int num_threads,
89  const std::function<void(int thread_id, int task_id)>& f);
90 } // namespace support
91 } // namespace tvm
92 
93 #endif // TVM_SUPPORT_PARALLEL_FOR_H_
std::function< std::vector< std::vector< int > >(int, int, int, int)> PartitionerFuncType
Definition: parallel_for.h:35
std::vector< std::vector< int > > rr_partitioner(int begin, int end, int step, int num_threads)
A partitioner to split the task to each thread in Round-robin manner.
void parallel_for(int begin, int end, const std::function< void(int)> &f, int step=1, const PartitionerFuncType partitioner=rr_partitioner)
A runtime api provided to run the task function in parallel. e.g. A for loop: for (int i = 0; i < 10;...
void parallel_for_dynamic(int begin, int end, int num_threads, const std::function< void(int thread_id, int task_id)> &f)
An API to launch fix amount of threads to run the specific functor in parallel. Different from parall...
runtime implementation for LibTorch/TorchScript.
Definition: analyzer.h:36