mirror of
https://github.com/pocoproject/poco.git
synced 2024-12-13 18:45:10 +01:00
86a4f0045e
* fix(Thread_POSIX): sleep() poor performance #3703 * chore(vscode): add file associations * fix(TaskManager): waits for all threads in the ThreadPool #3704 * fix(Thread): call std::this_thread::sleep_for() to sleep #3703 * fix(PollSet): wakeup fd is never read #3708 * feat(Thread): Add Thread::set/getAffinity() #3709 * doc(Thread): Thread::trySleep() assertion #3710 * fix(PollSet): wakeup fd is never read (windows portion and some other optimizations) #3708 * feat(SocketReactor): improvements #3713 * chore(ThreadTest): add missing include * fix(PollSet): wakeup fd is never read #3708 * fix(Any): #3682 #3683 #3692 #3712 * fix(mingw): lowercase winsock2 and iphlpapi to allow cross compile #3711 * feat(Thread): Add Thread::set/getAffinity() #3709 * chore(SocketReactor): one-liners inlined, removed redundant try/catch in dospatch, remove unused onBusy() * feat(SocketReactor): add socket to ErrorNotification * fix(SocketReactor): pollTimeout assignment and ConnectorTest leak
146 lines
3.5 KiB
C++
146 lines
3.5 KiB
C++
//
|
|
// TaskManager.h
|
|
//
|
|
// Library: Foundation
|
|
// Package: Tasks
|
|
// Module: Tasks
|
|
//
|
|
// Definition of the TaskManager class.
|
|
//
|
|
// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#ifndef Foundation_TaskManager_INCLUDED
|
|
#define Foundation_TaskManager_INCLUDED
|
|
|
|
|
|
#include "Poco/Foundation.h"
|
|
#include "Poco/Mutex.h"
|
|
#include "Poco/Task.h"
|
|
#include "Poco/AutoPtr.h"
|
|
#include "Poco/NotificationCenter.h"
|
|
#include "Poco/Timestamp.h"
|
|
#include <list>
|
|
|
|
|
|
namespace Poco {
|
|
|
|
|
|
class Notification;
|
|
class ThreadPool;
|
|
class Exception;
|
|
|
|
|
|
class Foundation_API TaskManager
|
|
/// The TaskManager manages a collection of tasks
|
|
/// and monitors their lifetime.
|
|
///
|
|
/// A TaskManager has a built-in NotificationCenter that
|
|
/// is used to send out notifications on task progress
|
|
/// and task states. See the TaskNotification class and its
|
|
/// subclasses for the various events that result in a notification.
|
|
/// To keep the number of notifications small, a TaskProgressNotification
|
|
/// will only be sent out once in 100 milliseconds.
|
|
{
|
|
public:
|
|
using TaskPtr = AutoPtr<Task>;
|
|
using TaskList = std::list<TaskPtr>;
|
|
|
|
TaskManager(const std::string& name = "",
|
|
int minCapacity = 2,
|
|
int maxCapacity = 16,
|
|
int idleTime = 60,
|
|
int stackSize = POCO_THREAD_STACK_SIZE);
|
|
/// Creates the TaskManager.
|
|
|
|
TaskManager(ThreadPool& pool);
|
|
/// Creates the TaskManager, using the
|
|
/// given ThreadPool (should be used
|
|
/// by this TaskManager exclusively).
|
|
|
|
~TaskManager();
|
|
/// Destroys the TaskManager.
|
|
|
|
void start(Task* pTask);
|
|
/// Starts the given task in a thread obtained
|
|
/// from the thread pool.
|
|
///
|
|
/// The TaskManager takes ownership of the Task object
|
|
/// and deletes it when it it finished.
|
|
|
|
void cancelAll();
|
|
/// Requests cancellation of all tasks.
|
|
|
|
void joinAll();
|
|
/// Waits for the completion of all the threads
|
|
/// in the TaskManager's thread pool.
|
|
///
|
|
/// Note: joinAll() will wait for ALL tasks in the
|
|
/// TaskManager's ThreadPool to complete. If the
|
|
/// ThreadPool has threads created by other
|
|
/// facilities, these threads must also complete
|
|
/// before joinAll() can return.
|
|
|
|
TaskList taskList() const;
|
|
/// Returns a copy of the internal task list.
|
|
|
|
int count() const;
|
|
/// Returns the number of tasks in the internal task list.
|
|
|
|
void addObserver(const AbstractObserver& observer);
|
|
/// Registers an observer with the NotificationCenter.
|
|
/// Usage:
|
|
/// Observer<MyClass, MyNotification> obs(*this, &MyClass::handleNotification);
|
|
/// notificationCenter.addObserver(obs);
|
|
|
|
void removeObserver(const AbstractObserver& observer);
|
|
/// Unregisters an observer with the NotificationCenter.
|
|
|
|
static const int MIN_PROGRESS_NOTIFICATION_INTERVAL;
|
|
|
|
protected:
|
|
void postNotification(const Notification::Ptr& pNf);
|
|
/// Posts a notification to the task manager's
|
|
/// notification center.
|
|
|
|
void taskStarted(Task* pTask);
|
|
void taskProgress(Task* pTask, float progress);
|
|
void taskCancelled(Task* pTask);
|
|
void taskFinished(Task* pTask);
|
|
void taskFailed(Task* pTask, const Exception& exc);
|
|
|
|
private:
|
|
using MutexT = FastMutex;
|
|
using ScopedLockT = MutexT::ScopedLock;
|
|
|
|
ThreadPool& _threadPool;
|
|
bool _ownPool;
|
|
TaskList _taskList;
|
|
Timestamp _lastProgressNotification;
|
|
NotificationCenter _nc;
|
|
mutable MutexT _mutex;
|
|
|
|
friend class Task;
|
|
};
|
|
|
|
|
|
//
|
|
// inlines
|
|
//
|
|
inline int TaskManager::count() const
|
|
{
|
|
ScopedLockT lock(_mutex);
|
|
|
|
return (int) _taskList.size();
|
|
}
|
|
|
|
|
|
} // namespace Poco
|
|
|
|
|
|
#endif // Foundation_TaskManager_INCLUDED
|