opencog-atomspace / opencog / atoms / parallel / ParallelLink.cc

/*
 * opencog/atoms/parallel/ParallelLink.cc
 *
 * Copyright (C) 2009, 2013, 2014, 2015, 2020 Linas Vepstas
 * SPDX-License-Identifier: AGPL-3.0-or-later
 * All Rights Reserved
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License v3 as
 * published by the Free Software Foundation and including the exceptions
 * at http://opencog.org/wiki/Licenses
 *
 * 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 Affero General Public License
 * along with this program; if not, write to:
 * Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#include <thread>

#include <opencog/util/platform.h>
#include <opencog/atoms/parallel/ParallelLink.h>
#include <opencog/atoms/value/VoidValue.h>
#include <opencog/atomspace/AtomSpace.h>
#include <opencog/eval/FrameStack.h>

using namespace opencog;

ParallelLink::ParallelLink(const HandleSeq&& oset, Type t)
    : UnorderedLink(std::move(oset), t)
{
}

static void thread_eval(AtomSpace* as,
                        const Handle& evelnk,
                        bool silent)
{
	set_thread_name("atoms:parallel");
	if (not evelnk->is_executable()) return;

	set_frame(AtomSpaceCast(as));
	try
	{
		ValuePtr pap(evelnk->execute(as, silent));
		if (pap and pap->is_atom())
			as->add_atom(HandleCast(pap));
	}
	catch (const std::exception& ex)
	{
		logger().warn("Caught exception in thread:\n%s", ex.what());
	}
}

ValuePtr ParallelLink::execute(AtomSpace* as,
                               bool silent)
{
	// Create and detach threads; return immediately.
	for (const Handle& h : _outgoing)
	{
		std::thread thr(&thread_eval, as, h, silent);
		thr.detach();
	}

	return createVoidValue();
}

DEFINE_LINK_FACTORY(ParallelLink, PARALLEL_LINK)