This is an archive of the discontinued LLVM Phabricator instance.

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Lines	mlirAsyncRuntimeAwaitToken(AsyncToken *token) {
std::unique_lock<std::mutex> lock(token->mu);		std::unique_lock<std::mutex> lock(token->mu);
if (!token->ready)		if (!token->ready)
token->cv.wait(lock, [token] { return token->ready; });		token->cv.wait(lock, [token] { return token->ready; });
delete token;		delete token;
}		}

extern "C" MLIR_ASYNCRUNTIME_EXPORT void		extern "C" MLIR_ASYNCRUNTIME_EXPORT void
mlirAsyncRuntimeExecute(CoroHandle handle, CoroResume resume) {		mlirAsyncRuntimeExecute(CoroHandle handle, CoroResume resume) {
(*resume)(handle);		std::thread thread([handle, resume]() { (*resume)(handle); });
		thread.detach();
		mehdi_aminiUnsubmitted Done Reply Inline Actions Should we guard for LLVM_ENABLE_THREAD? mehdi_amini: Should we guard for LLVM_ENABLE_THREAD?
}		}

extern "C" MLIR_ASYNCRUNTIME_EXPORT void		extern "C" MLIR_ASYNCRUNTIME_EXPORT void
mlirAsyncRuntimeAwaitTokenAndExecute(AsyncToken *token, CoroHandle handle,		mlirAsyncRuntimeAwaitTokenAndExecute(AsyncToken *token, CoroHandle handle,
CoroResume resume) {		CoroResume resume) {
std::unique_lock<std::mutex> lock(token->mu);		std::unique_lock<std::mutex> lock(token->mu);

auto execute = [token, handle, resume]() {		auto execute = [token, handle, resume]() {
Show All 21 Lines

mlir/lib/ExecutionEngine/CMakeLists.txt

	Show First 20 Lines • Show All 101 Lines • ▼ Show 20 Lines
	add_mlir_library(mlir_async_runtime			add_mlir_library(mlir_async_runtime
	SHARED			SHARED
	AsyncRuntime.cpp			AsyncRuntime.cpp

	EXCLUDE_FROM_LIBMLIR			EXCLUDE_FROM_LIBMLIR

	LINK_LIBS PUBLIC			LINK_LIBS PUBLIC
	mlir_c_runner_utils_static			mlir_c_runner_utils_static
				${LLVM_PTHREAD_LIB}
	)			)
	target_compile_definitions(mlir_async_runtime PRIVATE mlir_async_runtime_EXPORTS)			target_compile_definitions(mlir_async_runtime PRIVATE mlir_async_runtime_EXPORTS)