ThreadWeaver
SuspendingState.cpp
Go to the documentation of this file.00001 /* -*- C++ -*- 00002 00003 This file implements the SuspendingState class. 00004 00005 $ Author: Mirko Boehm $ 00006 $ Copyright: (C) 2005, 2006 Mirko Boehm $ 00007 $ Contact: mirko@kde.org 00008 http://www.kde.org 00009 http://www.hackerbuero.org $ 00010 00011 This library is free software; you can redistribute it and/or 00012 modify it under the terms of the GNU Library General Public 00013 License as published by the Free Software Foundation; either 00014 version 2 of the License, or (at your option) any later version. 00015 00016 This library is distributed in the hope that it will be useful, 00017 but WITHOUT ANY WARRANTY; without even the implied warranty of 00018 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00019 Library General Public License for more details. 00020 00021 You should have received a copy of the GNU Library General Public License 00022 along with this library; see the file COPYING.LIB. If not, write to 00023 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, 00024 Boston, MA 02110-1301, USA. 00025 00026 $Id: SuspendingState.cpp 30 2005-08-16 16:16:04Z mirko $ 00027 */ 00028 00029 #include "SuspendingState.h" 00030 00031 #include "State.h" 00032 #include "WeaverImpl.h" 00033 #include "ThreadWeaver.h" 00034 00035 using namespace ThreadWeaver; 00036 00037 void SuspendingState::suspend() 00038 { 00039 // this request is not handled in Suspending state (we are already 00040 // suspending...) 00041 } 00042 00043 void SuspendingState::resume() 00044 { 00045 weaver()->setState ( WorkingHard ); 00046 } 00047 00048 void SuspendingState::activated() 00049 { 00050 if ( weaver()->activeThreadCount() == 0 ) 00051 { 00052 weaver()->setState( Suspended ); 00053 } 00054 } 00055 00056 Job* SuspendingState::applyForWork ( Thread *th, Job* previous ) 00057 { 00058 if ( weaver()->activeThreadCount() == 0 ) 00059 { 00060 weaver()->setState ( Suspended ); 00061 } 00062 weaver()->waitForAvailableJob ( th ); 00063 return weaver()->applyForWork ( th, previous ); 00064 } 00065 00066 void SuspendingState::waitForAvailableJob ( Thread *th ) 00067 { 00068 weaver()->blockThreadUntilJobsAreBeingAssigned( th ); 00069 } 00070 00071 StateId SuspendingState::stateId() const 00072 { 00073 return Suspending; 00074 }