/**************************************************************************** ** ** Copyright (C) 2011 Nokia Corporation and/or its subsidiary(-ies). ** All rights reserved. ** Contact: Nokia Corporation (qt-info@nokia.com) ** ** This file is part of the QtCore module of the Qt Toolkit. ** ** $QT_BEGIN_LICENSE:LGPL$ ** No Commercial Usage ** This file contains pre-release code and may not be distributed. ** You may use this file in accordance with the terms and conditions ** contained in the Technology Preview License Agreement accompanying ** this package. ** ** GNU Lesser General Public License Usage ** Alternatively, this file may be used under the terms of the GNU Lesser ** General Public License version 2.1 as published by the Free Software ** Foundation and appearing in the file LICENSE.LGPL included in the ** packaging of this file. Please review the following information to ** ensure the GNU Lesser General Public License version 2.1 requirements ** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. ** ** In addition, as a special exception, Nokia gives you certain additional ** rights. These rights are described in the Nokia Qt LGPL Exception ** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. ** ** If you have questions regarding the use of this file, please contact ** Nokia at qt-info@nokia.com. ** ** ** ** ** ** ** ** ** $QT_END_LICENSE$ ** ****************************************************************************/ #ifndef QTCONCURRENT_FILTER_H #define QTCONCURRENT_FILTER_H #include #ifndef QT_NO_CONCURRENT #include #include QT_BEGIN_HEADER QT_BEGIN_NAMESPACE QT_MODULE(Core) #ifdef qdoc namespace QtConcurrent { QFuture filter(Sequence &sequence, FilterFunction filterFunction); template QFuture filtered(const Sequence &sequence, FilterFunction filterFunction); template QFuture filtered(ConstIterator begin, ConstIterator end, FilterFunction filterFunction); template QFuture filteredReduced(const Sequence &sequence, FilterFunction filterFunction, ReduceFunction reduceFunction, QtConcurrent::ReduceOptions reduceOptions = UnorderedReduce | SequentialReduce); template QFuture filteredReduced(ConstIterator begin, ConstIterator end, FilterFunction filterFunction, ReduceFunction reduceFunction, QtConcurrent::ReduceOptions reduceOptions = UnorderedReduce | SequentialReduce); void blockingFilter(Sequence &sequence, FilterFunction filterFunction); template Sequence blockingFiltered(const Sequence &sequence, FilterFunction filterFunction); template Sequence blockingFiltered(ConstIterator begin, ConstIterator end, FilterFunction filterFunction); template T blockingFilteredReduced(const Sequence &sequence, FilterFunction filterFunction, ReduceFunction reduceFunction, QtConcurrent::ReduceOptions reduceOptions = UnorderedReduce | SequentialReduce); template T blockingFilteredReduced(ConstIterator begin, ConstIterator end, FilterFunction filterFunction, ReduceFunction reduceFunction, QtConcurrent::ReduceOptions reduceOptions = UnorderedReduce | SequentialReduce); } // namespace QtConcurrent #else namespace QtConcurrent { template ThreadEngineStarter filterInternal(Sequence &sequence, KeepFunctor keep, T (C::*reduce)(U)) { typedef MemberFunctionWrapper1 ReduceFunctor; typedef typename Sequence::const_iterator Iterator; typedef FilterKernel KernelType; return startThreadEngine(new KernelType(sequence, keep, reduce)); } // filter() on sequences template QFuture filter(Sequence &sequence, KeepFunctor keep) { return filterInternal(sequence, keep, &Sequence::push_back); } template QFuture filter(Sequence &sequence, bool (keep)(T)) { return filterInternal(sequence, FunctionWrapper1(keep), &Sequence::push_back); } template QFuture filter(Sequence &sequence, bool (C::*keep)() const) { return filterInternal(sequence, ConstMemberFunctionWrapper(keep), &Sequence::push_back); } // filteredReduced() on sequences template QFuture filteredReduced(const Sequence &sequence, KeepFunctor keep, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startFilteredReduced(sequence, keep, reduce, options); } template QFuture filteredReduced(const Sequence &sequence, bool (filter)(T), ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, FunctionWrapper1(filter), reduce, options); } template QFuture filteredReduced(const Sequence &sequence, bool (C::*filter)() const, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, ConstMemberFunctionWrapper(filter), reduce, options); } template QFuture filteredReduced(const Sequence &sequence, KeepFunctor keep, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, keep, FunctionWrapper2(reduce), options); } template QFuture filteredReduced(const Sequence &sequence, KeepFunctor keep, T (C::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, keep, MemberFunctionWrapper1(reduce), options); } template QFuture filteredReduced(const Sequence &sequence, bool (keep)(T), U (reduce)(V &, W), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, FunctionWrapper1(keep), FunctionWrapper2(reduce), options); } template QFuture filteredReduced(const Sequence &sequence, bool (C::*keep)() const, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, ConstMemberFunctionWrapper(keep), FunctionWrapper2(reduce), options); } template QFuture filteredReduced(const Sequence &sequence, bool (keep)(T), U (C::*reduce)(V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, FunctionWrapper1(keep), MemberFunctionWrapper1(reduce), options); } template QFuture filteredReduced(const Sequence &sequence, bool (C::*keep)() const, T (D::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(sequence, ConstMemberFunctionWrapper(keep), MemberFunctionWrapper1(reduce), options); } // filteredReduced() on iterators template QFuture filteredReduced(Iterator begin, Iterator end, KeepFunctor keep, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startFilteredReduced(begin, end, keep, reduce, options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (filter)(T), ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, FunctionWrapper1(filter), reduce, options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (C::*filter)() const, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, ConstMemberFunctionWrapper(filter), reduce, options); } template QFuture filteredReduced(Iterator begin, Iterator end, KeepFunctor keep, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, keep, FunctionWrapper2(reduce), options); } template QFuture filteredReduced(Iterator begin, Iterator end, KeepFunctor keep, T (C::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, keep, MemberFunctionWrapper1(reduce), options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (keep)(T), U (reduce)(V &, W), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, FunctionWrapper1(keep), FunctionWrapper2(reduce), options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (C::*keep)() const, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, ConstMemberFunctionWrapper(keep), FunctionWrapper2(reduce), options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (keep)(T), U (C::*reduce)(V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, FunctionWrapper1(keep), MemberFunctionWrapper1(reduce), options); } template QFuture filteredReduced(Iterator begin, Iterator end, bool (C::*keep)() const, T (D::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return filteredReduced(begin, end, ConstMemberFunctionWrapper(keep), MemberFunctionWrapper1(reduce), options); } // filtered() on sequences template QFuture filtered(const Sequence &sequence, KeepFunctor keep) { return startFiltered(sequence, keep); } template QFuture filtered(const Sequence &sequence, bool (keep)(T)) { return startFiltered(sequence, FunctionWrapper1(keep)); } template QFuture filtered(const Sequence &sequence, bool (C::*keep)() const) { return startFiltered(sequence, ConstMemberFunctionWrapper(keep)); } // filtered() on iterators template QFuture::value_type> filtered(Iterator begin, Iterator end, KeepFunctor keep) { return startFiltered(begin, end, keep); } template QFuture::value_type> filtered(Iterator begin, Iterator end, bool (keep)(T)) { return startFiltered(begin, end, FunctionWrapper1(keep)); } template QFuture::value_type> filtered(Iterator begin, Iterator end, bool (C::*keep)() const) { return startFiltered(begin, end, ConstMemberFunctionWrapper(keep)); } // blocking filter() on sequences template void blockingFilter(Sequence &sequence, KeepFunctor keep) { filterInternal(sequence, keep, &Sequence::push_back).startBlocking(); } template void blockingFilter(Sequence &sequence, bool (keep)(T)) { filterInternal(sequence, FunctionWrapper1(keep), &Sequence::push_back) .startBlocking(); } template void blockingFilter(Sequence &sequence, bool (C::*keep)() const) { filterInternal(sequence, ConstMemberFunctionWrapper(keep), &Sequence::push_back) .startBlocking(); } // blocking filteredReduced() on sequences template ResultType blockingFilteredReduced(const Sequence &sequence, KeepFunctor keep, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startFilteredReduced(sequence, keep, reduce, options) .startBlocking(); } template ResultType blockingFilteredReduced(const Sequence &sequence, bool (filter)(T), ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, FunctionWrapper1(filter), reduce, options); } template ResultType blockingFilteredReduced(const Sequence &sequence, bool (C::*filter)() const, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, ConstMemberFunctionWrapper(filter), reduce, options); } template U blockingFilteredReduced(const Sequence &sequence, KeepFunctor keep, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, keep, FunctionWrapper2(reduce), options); } template C blockingFilteredReduced(const Sequence &sequence, KeepFunctor keep, T (C::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, keep, MemberFunctionWrapper1(reduce), options); } template V blockingFilteredReduced(const Sequence &sequence, bool (keep)(T), U (reduce)(V &, W), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, FunctionWrapper1(keep), FunctionWrapper2(reduce), options); } template U blockingFilteredReduced(const Sequence &sequence, bool (C::*keep)() const, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, ConstMemberFunctionWrapper(keep), FunctionWrapper2(reduce), options); } template C blockingFilteredReduced(const Sequence &sequence, bool (keep)(T), U (C::*reduce)(V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, FunctionWrapper1(keep), MemberFunctionWrapper1(reduce), options); } template D blockingFilteredReduced(const Sequence &sequence, bool (C::*keep)() const, T (D::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (sequence, ConstMemberFunctionWrapper(keep), MemberFunctionWrapper1(reduce), options); } // blocking filteredReduced() on iterators template ResultType blockingFilteredReduced(Iterator begin, Iterator end, KeepFunctor keep, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return startFilteredReduced(begin, end, keep, reduce, options) .startBlocking(); } template ResultType blockingFilteredReduced(Iterator begin, Iterator end, bool (filter)(T), ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, FunctionWrapper1(filter), reduce, options); } template ResultType blockingFilteredReduced(Iterator begin, Iterator end, bool (C::*filter)() const, ReduceFunctor reduce, ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, ConstMemberFunctionWrapper(filter), reduce, options); } template U blockingFilteredReduced(Iterator begin, Iterator end, KeepFunctor keep, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, keep, FunctionWrapper2(reduce), options); } template C blockingFilteredReduced(Iterator begin, Iterator end, KeepFunctor keep, T (C::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, keep, MemberFunctionWrapper1(reduce), options); } template V blockingFilteredReduced(Iterator begin, Iterator end, bool (keep)(T), U (reduce)(V &, W), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, FunctionWrapper1(keep), FunctionWrapper2(reduce), options); } template U blockingFilteredReduced(Iterator begin, Iterator end, bool (C::*keep)() const, T (reduce)(U &, V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, ConstMemberFunctionWrapper(keep), FunctionWrapper2(reduce), options); } template C blockingFilteredReduced(Iterator begin, Iterator end, bool (keep)(T), U (C::*reduce)(V), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, FunctionWrapper1(keep), MemberFunctionWrapper1(reduce), options); } template D blockingFilteredReduced(Iterator begin, Iterator end, bool (C::*keep)() const, T (D::*reduce)(U), ReduceOptions options = ReduceOptions(UnorderedReduce | SequentialReduce)) { return blockingFilteredReduced (begin, end, ConstMemberFunctionWrapper(keep), MemberFunctionWrapper1(reduce), options); } // blocking filtered() on sequences template Sequence blockingFiltered(const Sequence &sequence, KeepFunctor keep) { return blockingFilteredReduced(sequence, keep, &Sequence::push_back, OrderedReduce); } template Sequence blockingFiltered(const Sequence &sequence, bool (keep)(T)) { return blockingFilteredReduced(sequence, keep, &Sequence::push_back, OrderedReduce); } template Sequence blockingFiltered(const Sequence &sequence, bool (C::*filter)() const) { return blockingFilteredReduced(sequence, filter, &Sequence::push_back, OrderedReduce); } // blocking filtered() on iterators template OutputSequence blockingFiltered(Iterator begin, Iterator end, KeepFunctor keep) { return blockingFilteredReduced(begin, end, keep, &OutputSequence::push_back, OrderedReduce); } template OutputSequence blockingFiltered(Iterator begin, Iterator end, bool (keep)(T)) { return blockingFilteredReduced(begin, end, keep, &OutputSequence::push_back, OrderedReduce); } template OutputSequence blockingFiltered(Iterator begin, Iterator end, bool (C::*filter)() const) { return blockingFilteredReduced(begin, end, filter, &OutputSequence::push_back, OrderedReduce); } } // namespace QtConcurrent #endif // qdoc QT_END_NAMESPACE QT_END_HEADER #endif // QT_NO_CONCURRENT #endif