/* * This file is part of OpenTTD. * OpenTTD 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, version 2. * OpenTTD 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 OpenTTD. If not, see <http://www.gnu.org/licenses/>. *//** @file thread.h Base of all threads. */#ifndef THREAD_H#define THREAD_H#include"debug.h"#include"crashlog.h"#include<system_error>#include<thread>#include<mutex>/** * Sleep on the current thread for a defined time. * @param milliseconds Time to sleep for in milliseconds. */inlinevoidCSleep(intmilliseconds){std::this_thread::sleep_for(std::chrono::milliseconds(milliseconds));}/** * Name the thread this function is called on for the debugger. * @param name Name to set for the thread.. */voidSetCurrentThreadName(constchar*name);/** * Start a new thread. * @tparam TFn Type of the function to call on the thread. * @tparam TArgs Type of the parameters of the thread function. * @param thr Pointer to a thread object; may be \c nullptr if a detached thread is wanted. * @param name Name of the thread. * @param _Fx Function to call on the thread. * @param _Ax Arguments for the thread function. * @return True if the thread was successfully started, false otherwise. */template<classTFn,class...TArgs>inlineboolStartNewThread(std::thread*thr,constchar*name,TFn&&_Fx,TArgs&&..._Ax){try{staticstd::mutexthread_startup_mutex;std::lock_guard<std::mutex>lock(thread_startup_mutex);std::threadt([](constchar*name,TFn&&F,TArgs&&...A){/* Delay starting the thread till the main thread is finished * with the administration. This prevent race-conditions on * startup. */{std::lock_guard<std::mutex>lock(thread_startup_mutex);}SetCurrentThreadName(name);CrashLog::InitThread();try{/* Call user function with the given arguments. */F(A...);}catch(...){NOT_REACHED();}},name,std::forward<TFn>(_Fx),std::forward<TArgs>(_Ax)...);if(thr!=nullptr){*thr=std::move(t);}else{t.detach();}returntrue;}catch(conststd::system_error&e){/* Something went wrong, the system we are running on might not support threads. */Debug(misc,1,"Can't create thread '{}': {}",name,e.what());}returnfalse;}#endif /* THREAD_H */