ce49d99c2f
Since we switched from autotools to Meson in commit
94592c1406, we don't need to include
`config.h` early to properly enable large file support. Meson passes
the required macros on the compiler command line instead of defining
them in `config.h`.
This means we can include `config.h` at any time, whenever we want to
check its macros, and there are no ordering constraints.
118 lines
2.6 KiB
C++
118 lines
2.6 KiB
C++
/*
|
|
* Copyright 2003-2018 The Music Player Daemon Project
|
|
* http://www.musicpd.org
|
|
*
|
|
* 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.
|
|
*/
|
|
|
|
#ifndef MPD_THREAD_HXX
|
|
#define MPD_THREAD_HXX
|
|
|
|
#include "util/BindMethod.hxx"
|
|
#include "util/Compiler.h"
|
|
|
|
#ifdef _WIN32
|
|
#include <windows.h>
|
|
#else
|
|
#include <pthread.h>
|
|
#endif
|
|
|
|
#include <assert.h>
|
|
|
|
class Thread {
|
|
typedef BoundMethod<void()> Function;
|
|
const Function f;
|
|
|
|
#ifdef _WIN32
|
|
HANDLE handle = nullptr;
|
|
DWORD id;
|
|
#else
|
|
pthread_t handle = pthread_t();
|
|
|
|
#ifndef NDEBUG
|
|
/**
|
|
* This handle is only used by IsInside(), and is set by the
|
|
* thread function. Since #handle is set by pthread_create()
|
|
* which is racy, we need this attribute for early checks
|
|
* inside the thread function.
|
|
*/
|
|
pthread_t inside_handle = pthread_t();
|
|
#endif
|
|
#endif
|
|
|
|
public:
|
|
explicit Thread(Function _f) noexcept:f(_f) {}
|
|
|
|
Thread(const Thread &) = delete;
|
|
Thread &operator=(const Thread &) = delete;
|
|
|
|
#ifndef NDEBUG
|
|
~Thread() noexcept {
|
|
/* all Thread objects must be destructed manually by calling
|
|
Join(), to clean up */
|
|
assert(!IsDefined());
|
|
}
|
|
#endif
|
|
|
|
bool IsDefined() const noexcept {
|
|
#ifdef _WIN32
|
|
return handle != nullptr;
|
|
#else
|
|
return handle != pthread_t();
|
|
#endif
|
|
}
|
|
|
|
#ifndef NDEBUG
|
|
/**
|
|
* Check if this thread is the current thread.
|
|
*/
|
|
gcc_pure
|
|
bool IsInside() const noexcept {
|
|
#ifdef _WIN32
|
|
return GetCurrentThreadId() == id;
|
|
#else
|
|
/* note: not using pthread_equal() because that
|
|
function "is undefined if either thread ID is not
|
|
valid so we can't safely use it on
|
|
default-constructed values" (comment from
|
|
libstdc++) - and if both libstdc++ and libc++ get
|
|
away with this, we can do it as well */
|
|
return pthread_self() == inside_handle;
|
|
#endif
|
|
}
|
|
#endif
|
|
|
|
/**
|
|
* Start the thread.
|
|
*
|
|
* Throws on error.
|
|
*/
|
|
void Start();
|
|
|
|
void Join() noexcept;
|
|
|
|
private:
|
|
void Run() noexcept;
|
|
|
|
#ifdef _WIN32
|
|
static DWORD WINAPI ThreadProc(LPVOID ctx) noexcept;
|
|
#else
|
|
static void *ThreadProc(void *ctx) noexcept;
|
|
#endif
|
|
|
|
};
|
|
|
|
#endif
|