/**************************************************************************** ** ** Copyright (C) 2021 The Qt Company Ltd. ** Contact: https://www.qt.io/licensing/ ** ** This file is part of the QtConcurrent module of the Qt Toolkit. ** ** $QT_BEGIN_LICENSE:COMM$ ** ** Commercial License Usage ** Licensees holding valid commercial Qt licenses may use this file in ** accordance with the commercial license agreement provided with the ** Software or, alternatively, in accordance with the terms contained in ** a written agreement between you and The Qt Company. For licensing terms ** and conditions see https://www.qt.io/terms-conditions. For further ** information use the contact form at https://www.qt.io/contact-us. ** ** $QT_END_LICENSE$ ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ****************************************************************************/ #ifndef QTCONCURRENT_MAP_H #define QTCONCURRENT_MAP_H #include #if !defined(QT_NO_CONCURRENT) || defined(Q_CLANG_QDOC) #include #include #include #include QT_BEGIN_NAMESPACE namespace QtConcurrent { // map() on sequences template QFuture map(Sequence &sequence, MapFunctor map) { return startMap(sequence.begin(), sequence.end(), QtPrivate::createFunctionWrapper(map)); } // map() on iterators template QFuture map(Iterator begin, Iterator end, MapFunctor map) { return startMap(begin, end, QtPrivate::createFunctionWrapper(map)); } // mappedReduced() for sequences. template QFuture mappedReduced(const Sequence &sequence, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startMappedReduced::ResultType, ResultType> (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); } template QFuture::ResultType> mappedReduced(const Sequence &sequence, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startMappedReduced::ResultType, typename QtPrivate::ReduceResultType::ResultType> (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); } // mappedReduced() for iterators template QFuture mappedReduced(Iterator begin, Iterator end, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startMappedReduced::ResultType, ResultType> (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); } template QFuture::ResultType> mappedReduced(Iterator begin, Iterator end, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startMappedReduced::ResultType, typename QtPrivate::ReduceResultType::ResultType> (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); } // mapped() for sequences template QFuture::ResultType> mapped(const Sequence &sequence, MapFunctor map) { return startMapped::ResultType>(sequence, QtPrivate::createFunctionWrapper(map)); } // mapped() for iterator ranges. template QFuture::ResultType> mapped(Iterator begin, Iterator end, MapFunctor map) { return startMapped::ResultType>(begin, end, QtPrivate::createFunctionWrapper(map)); } // blockingMap() for sequences template void blockingMap(Sequence &sequence, MapFunctor map) { QFuture future = startMap(sequence.begin(), sequence.end(), QtPrivate::createFunctionWrapper(map)); future.waitForFinished(); } // blockingMap() for iterator ranges template void blockingMap(Iterator begin, Iterator end, MapFunctor map) { QFuture future = startMap(begin, end, QtPrivate::createFunctionWrapper(map)); future.waitForFinished(); } // blockingMappedReduced() for sequences template ResultType blockingMappedReduced(const Sequence &sequence, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { QFuture future = QtConcurrent::startMappedReduced::ResultType, ResultType> (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); return future.result(); } template typename QtPrivate::ReduceResultType::ResultType blockingMappedReduced(const Sequence &sequence, MapFunctor map, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { QFuture::ResultType> future = QtConcurrent::startMappedReduced::ResultType, typename QtPrivate::ReduceResultType::ResultType> (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); return future.result(); } // blockingMappedReduced() for iterator ranges template ResultType blockingMappedReduced(Iterator begin, Iterator end, MapFunctor map, ReduceFunctor reduce, QtConcurrent::ReduceOptions options = QtConcurrent::ReduceOptions(QtConcurrent::UnorderedReduce | QtConcurrent::SequentialReduce)) { QFuture future = QtConcurrent::startMappedReduced::ResultType, ResultType> (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); return future.result(); } template typename QtPrivate::ReduceResultType::ResultType blockingMappedReduced(Iterator begin, Iterator end, MapFunctor map, ReduceFunctor reduce, QtConcurrent::ReduceOptions options = QtConcurrent::ReduceOptions(QtConcurrent::UnorderedReduce | QtConcurrent::SequentialReduce)) { QFuture::ResultType> future = QtConcurrent::startMappedReduced::ResultType, typename QtPrivate::ReduceResultType::ResultType> (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::createFunctionWrapper(reduce), options); return future.result(); } // mapped() for sequences with a different putput sequence type. template OutputSequence blockingMapped(const InputSequence &sequence, MapFunctor map) { return blockingMappedReduced (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::PushBackWrapper(), QtConcurrent::OrderedReduce); } template typename QtPrivate::MapResultType::ResultType blockingMapped(const InputSequence &sequence, MapFunctor map) { typedef typename QtPrivate::MapResultType::ResultType OutputSequence; return blockingMappedReduced (sequence, QtPrivate::createFunctionWrapper(map), QtPrivate::PushBackWrapper(), QtConcurrent::OrderedReduce); } // mapped() for iterator ranges template Sequence blockingMapped(Iterator begin, Iterator end, MapFunctor map) { return blockingMappedReduced (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::PushBackWrapper(), QtConcurrent::OrderedReduce); } template typename QtPrivate::MapResultType::ResultType blockingMapped(Iterator begin, Iterator end, MapFunctor map) { typedef typename QtPrivate::MapResultType::ResultType OutputSequence; return blockingMappedReduced (begin, end, QtPrivate::createFunctionWrapper(map), QtPrivate::PushBackWrapper(), QtConcurrent::OrderedReduce); } } // namespace QtConcurrent QT_END_NAMESPACE #endif // QT_NO_CONCURRENT #endif