item_with_predicate.cpp

Go to the documentation of this file.

// Copyright (c) 2013-2025  Made to Order Software Corp.  All Rights Reserved
//
// https://snapwebsites.org/project/cppthread
// contact@m2osw.com
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 
// self
//
#include    "cppthread/item_with_predicate.h"
 
#include    "cppthread/exception.h"
#include    "cppthread/guard.h"
 
 
// C++
//
#include    <iostream>
 
 
 
namespace cppthread
{
 
 
 
item_with_predicate::item_with_predicate(pointer_t dependency)
    : f_dependencies({ dependency })
{
}
 
 
item_with_predicate::item_with_predicate(dependencies_t const & dependencies)
    : f_dependencies(dependencies)
{
}
 
 
item_with_predicate::~item_with_predicate()
{
}
 
 
void item_with_predicate::add_dependency(pointer_t item)
{
    guard lock(f_mutex);
 
    if(f_processing)
    {
        throw in_use_error("workload already being processed, you can't add more dependencies to it.");
    }
 
    f_dependencies.push_back(item);
}
 
 
void item_with_predicate::add_dependencies(dependencies_t const & dependencies)
{
    guard lock(f_mutex);
 
    if(f_processing)
    {
        throw in_use_error("workload already being processed, you can't add more dependencies to it.");
    }
 
    f_dependencies.insert(f_dependencies.begin(), dependencies.cbegin(), dependencies.cend());
}
 
 
bool item_with_predicate::valid_workload() const
{
    guard lock(f_mutex);
 
    for(auto it(f_dependencies.begin()); it != f_dependencies.end(); )
    {
        if(it->expired())
        {
            it = f_dependencies.erase(it);
        }
        else
        {
            ++it;
        }
    }
 
    if(f_dependencies.empty())
    {
        f_processing = true;
        return true;
    }
 
    return false;
}
 
 
 
 
 
} // namespace cppthread
// vim: ts=4 sw=4 et