1/* 2 * Copyright (C) 2011 University of Szeged 3 * Copyright (C) 2011 Gabor Loki <loki@webkit.org> 4 * All rights reserved. 5 * 6 * Redistribution and use in source and binary forms, with or without 7 * modification, are permitted provided that the following conditions 8 * are met: 9 * 1. Redistributions of source code must retain the above copyright 10 * notice, this list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright 12 * notice, this list of conditions and the following disclaimer in the 13 * documentation and/or other materials provided with the distribution. 14 * 15 * THIS SOFTWARE IS PROVIDED BY UNIVERSITY OF SZEGED ``AS IS'' AND ANY 16 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 17 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 18 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL UNIVERSITY OF SZEGED OR 19 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 20 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 22 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY 23 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 25 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 26 */ 27 28#ifndef ParallelJobsGeneric_h 29#define ParallelJobsGeneric_h 30 31#if ENABLE(THREADING_GENERIC) 32 33#include <wtf/RefCounted.h> 34#include <wtf/Threading.h> 35 36namespace WTF { 37 38class ParallelEnvironment { 39 WTF_MAKE_FAST_ALLOCATED; 40public: 41 typedef void (*ThreadFunction)(void*); 42 43 WTF_EXPORT_PRIVATE ParallelEnvironment(ThreadFunction, size_t sizeOfParameter, int requestedJobNumber); 44 45 int numberOfJobs() 46 { 47 return m_numberOfJobs; 48 } 49 50 WTF_EXPORT_PRIVATE void execute(void* parameters); 51 52 class ThreadPrivate : public RefCounted<ThreadPrivate> { 53 public: 54 ThreadPrivate() 55 : m_threadID(0) 56 , m_running(false) 57 , m_parent(0) 58 { 59 } 60 61 bool tryLockFor(ParallelEnvironment*); 62 63 void execute(ThreadFunction, void*); 64 65 void waitForFinish(); 66 67 static PassRefPtr<ThreadPrivate> create() 68 { 69 return adoptRef(new ThreadPrivate()); 70 } 71 72 static void workerThread(void*); 73 74 private: 75 ThreadIdentifier m_threadID; 76 bool m_running; 77 ParallelEnvironment* m_parent; 78 79 mutable Mutex m_mutex; 80 ThreadCondition m_threadCondition; 81 82 ThreadFunction m_threadFunction; 83 void* m_parameters; 84 }; 85 86private: 87 ThreadFunction m_threadFunction; 88 size_t m_sizeOfParameter; 89 int m_numberOfJobs; 90 91 Vector< RefPtr<ThreadPrivate> > m_threads; 92 static Vector< RefPtr<ThreadPrivate> >* s_threadPool; 93}; 94 95} // namespace WTF 96 97#endif // ENABLE(THREADING_GENERIC) 98 99 100#endif // ParallelJobsGeneric_h 101