mirror of
git://sourceware.org/git/libabigail.git
synced 2024-12-23 02:02:15 +00:00
64e7901956
Update the copyright years for 2023, using the script update-copyright.sh. * update-copyright.sh: Update the copyright years in this script. * include/abg-comp-filter.h: Update copyright year for 2023. * include/abg-comparison.h: Likewise. * include/abg-config.h: Likewise. * include/abg-corpus.h: Likewise. * include/abg-ctf-reader.h: Likewise. * include/abg-cxx-compat.h: Likewise. * include/abg-diff-utils.h: Likewise. * include/abg-dwarf-reader.h: Likewise. * include/abg-elf-based-reader.h: Likewise. * include/abg-elf-reader.h: Likewise. * include/abg-fe-iface.h: Likewise. * include/abg-fwd.h: Likewise. * include/abg-hash.h: Likewise. * include/abg-ini.h: Likewise. * include/abg-interned-str.h: Likewise. * include/abg-ir.h: Likewise. * include/abg-libxml-utils.h: Likewise. * include/abg-reader.h: Likewise. * include/abg-regex.h: Likewise. * include/abg-reporter.h: Likewise. * include/abg-sptr-utils.h: Likewise. * include/abg-suppression.h: Likewise. * include/abg-tools-utils.h: Likewise. * include/abg-traverse.h: Likewise. * include/abg-viz-common.h: Likewise. * include/abg-viz-dot.h: Likewise. * include/abg-viz-svg.h: Likewise. * include/abg-workers.h: Likewise. * include/abg-writer.h: Likewise. * src/abg-comp-filter.cc: Likewise. * src/abg-comparison-priv.h: Likewise. * src/abg-comparison.cc: Likewise. * src/abg-config.cc: Likewise. * src/abg-corpus-priv.h: Likewise. * src/abg-corpus.cc: Likewise. * src/abg-ctf-reader.cc: Likewise. * src/abg-default-reporter.cc: Likewise. * src/abg-diff-utils.cc: Likewise. * src/abg-dwarf-reader.cc: Likewise. * src/abg-elf-based-reader.cc: Likewise. * src/abg-elf-helpers.cc: Likewise. * src/abg-elf-helpers.h: Likewise. * src/abg-elf-reader.cc: Likewise. * src/abg-fe-iface.cc: Likewise. * src/abg-hash.cc: Likewise. * src/abg-ini.cc: Likewise. * src/abg-internal.h: Likewise. * src/abg-ir-priv.h: Likewise. * src/abg-ir.cc: Likewise. * src/abg-leaf-reporter.cc: Likewise. * src/abg-libxml-utils.cc: Likewise. * src/abg-reader.cc: Likewise. * src/abg-regex.cc: Likewise. * src/abg-reporter-priv.cc: Likewise. * src/abg-reporter-priv.h: Likewise. * src/abg-suppression-priv.h: Likewise. * src/abg-suppression.cc: Likewise. * src/abg-symtab-reader.cc: Likewise. * src/abg-symtab-reader.h: Likewise. * src/abg-tools-utils.cc: Likewise. * src/abg-traverse.cc: Likewise. * src/abg-viz-common.cc: Likewise. * src/abg-viz-dot.cc: Likewise. * src/abg-viz-svg.cc: Likewise. * src/abg-workers.cc: Likewise. * src/abg-writer.cc: Likewise. * tests/print-diff-tree.cc: Likewise. * tests/test-abicompat.cc: Likewise. * tests/test-abidiff-exit.cc: Likewise. * tests/test-abidiff.cc: Likewise. * tests/test-alt-dwarf-file.cc: Likewise. * tests/test-core-diff.cc: Likewise. * tests/test-cxx-compat.cc: Likewise. * tests/test-diff-dwarf-abixml.cc: Likewise. * tests/test-diff-dwarf.cc: Likewise. * tests/test-diff-filter.cc: Likewise. * tests/test-diff-pkg.cc: Likewise. * tests/test-diff-suppr.cc: Likewise. * tests/test-diff2.cc: Likewise. * tests/test-dot.cc: Likewise. * tests/test-elf-helpers.cc: Likewise. * tests/test-ini.cc: Likewise. * tests/test-ir-walker.cc: Likewise. * tests/test-kmi-whitelist.cc: Likewise. * tests/test-lookup-syms.cc: Likewise. * tests/test-read-ctf.cc: Likewise. * tests/test-read-dwarf.cc: Likewise. * tests/test-read-write.cc: Likewise. * tests/test-svg.cc: Likewise. * tests/test-symtab-reader.cc: Likewise. * tests/test-symtab.cc: Likewise. * tests/test-tools-utils.cc: Likewise. * tests/test-types-stability.cc: Likewise. * tests/test-utils.cc: Likewise. * tests/test-utils.h: Likewise. * tools/abicompat.cc: Likewise. * tools/abidiff.cc: Likewise. * tools/abidw.cc: Likewise. * tools/abilint.cc: Likewise. * tools/abipkgdiff.cc: Likewise. * tools/abisym.cc: Likewise. * tools/binilint.cc: Likewise. * tools/kmidiff.cc: Likewise. Signed-off-by: Dodji Seketeli <dodji@redhat.com>
102 lines
2.6 KiB
C++
102 lines
2.6 KiB
C++
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
|
|
// -*- Mode: C++ -*-
|
|
//
|
|
// Copyright (C) 2013-2023 Red Hat, Inc.
|
|
//
|
|
// Author: Dodji Seketeli
|
|
|
|
/// @file
|
|
///
|
|
/// This file declares an interface for the worker threads (or thread
|
|
/// pool) design pattern. It aims at performing a set of tasks in
|
|
/// parallel, using the multi-threading capabilities of the underlying
|
|
/// processor(s).
|
|
///
|
|
|
|
#ifndef __ABG_WORKERS_H__
|
|
#define __ABG_WORKERS_H__
|
|
|
|
#include <memory>
|
|
#include <vector>
|
|
|
|
using std::shared_ptr;
|
|
|
|
namespace abigail
|
|
{
|
|
|
|
/// The namespace of the worker threads (or thread pool)
|
|
/// implementation of libabigail. This was modelled after the article
|
|
/// https://en.wikipedia.org/wiki/Thread_pool.
|
|
namespace workers
|
|
{
|
|
|
|
size_t get_number_of_threads();
|
|
|
|
/// This represents a task to be performed.
|
|
///
|
|
/// Each instance of this type represents a task that can be performed
|
|
/// concurrently to other instance of the same type.
|
|
///
|
|
/// An instance of @ref task is meant to be performed by a worker
|
|
/// (thread). A set of tasks can be stored in a @ref queue.
|
|
class task
|
|
{
|
|
public:
|
|
virtual void
|
|
perform() = 0;
|
|
|
|
virtual ~task(){};
|
|
}; // end class task.
|
|
|
|
typedef shared_ptr<task> task_sptr;
|
|
|
|
/// This represents a queue of tasks to be performed.
|
|
///
|
|
/// Tasks are performed by a number of worker threads.
|
|
///
|
|
/// When a task is inserted into a @ref queue, the task is said to be
|
|
/// "scheduled for execution".
|
|
///
|
|
/// This is because there are worker threads waiting for tasks to be
|
|
/// added to the queue. When a task is added to the queue, a worker
|
|
/// thread picks it up, executes it, notifies interested listeners
|
|
/// when the @ref task's execution is completed, and waits for another
|
|
/// task to be added to the queue.
|
|
///
|
|
/// Of course, several worker threads can execute tasks concurrently.
|
|
class queue
|
|
{
|
|
public:
|
|
struct priv;
|
|
|
|
/// A convenience typedef for a vector of @ref task_sptr
|
|
typedef std::vector<task_sptr> tasks_type;
|
|
|
|
private:
|
|
std::unique_ptr<priv> p_;
|
|
|
|
public:
|
|
struct task_done_notify;
|
|
queue();
|
|
queue(unsigned number_of_workers);
|
|
queue(unsigned number_of_workers,
|
|
task_done_notify& notifier);
|
|
size_t get_size() const;
|
|
bool schedule_task(const task_sptr&);
|
|
bool schedule_tasks(const tasks_type&);
|
|
void wait_for_workers_to_complete();
|
|
tasks_type& get_completed_tasks() const;
|
|
~queue();
|
|
}; // end class queue
|
|
|
|
/// This functor is to notify listeners that a given task scheduled
|
|
/// for execution has been fully executed.
|
|
struct queue::task_done_notify
|
|
{
|
|
virtual void
|
|
operator()(const task_sptr& task_done);
|
|
};
|
|
} // end namespace workers
|
|
} // end namespace abigail
|
|
#endif // __ABG_WORKERS_H__
|