Add create_files

Project.toml

@@ -6,6 +6,7 @@ version = "0.4.3"
 ClusterManagers = "34f1f09b-3a8b-5176-ab39-66d58a4d544e"
 Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"
 LinearAlgebra = "37e2e46d-f89d-539d-b4ee-838fcccc9c8e"
+Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"
 Parameters = "d96e819e-fc66-5662-9728-84c9c7592b0a"
 Pkg = "44cfe95a-1eb2-52ea-b672-e2afdf69b78f"
 ThreadPinning = "811555cd-349b-4f26-b7bc-1f208b848042"
@@ -14,6 +15,7 @@ ThreadPinning = "811555cd-349b-4f26-b7bc-1f208b848042"
 ClusterManagers = "0.4.6"
 Distributed = "1"
 LinearAlgebra = "1"
+Logging = "1"
 Parameters = "0.12, 0.13"
 Pkg = "1"
 ThreadPinning = "0.7.22"

src/ParallelProcessingTools.jl

@@ -13,8 +13,12 @@ import Pkg
 import ClusterManagers
 import ThreadPinning
 
+using Logging: @logmsg, LogLevel, Info, Debug
+
 using Parameters: @with_kw
 
+include("exceptions.jl")
+include("fileio.jl")
 include("threadsafe.jl")
 include("threadlocal.jl")
 include("onthreads.jl")

src/exceptions.jl

@@ -0,0 +1,50 @@
+# This file is a part of ParallelProcessingTools.jl, licensed under the MIT License (MIT).
+
+"""
+    ParallelProcessingTools.original_exception(err)
+
+Replaces `TaskFailedException`s and `RemoteException`s with the underlying
+exception that originated within the task or on the remote process.
+"""
+function original_exception end
+
+original_exception(err) = err
+original_exception(err::CompositeException) = CompositeException(original_exception.(err.exceptions))
+original_exception(err::TaskFailedException) = err.task.result
+original_exception(err::RemoteException) = err.captured.ex
+
+
+"""
+    ParallelProcessingTools.onlyfirst_exception(err)
+
+Replaces `CompositeException`s with their first exception.
+
+Also employs `original_exception` if `simplify` is `true`.
+"""
+function onlyfirst_exception end
+
+onlyfirst_exception(err) = err
+onlyfirst_exception(err::CompositeException) = first(err.exceptions)
+
+
+"""
+    @userfriendly_exceptions expr
+
+Transforms exceptions originating from `expr` into more user-friendly ones.
+
+If multiple exceptions originate from parallel code in `expr`, only one
+is rethrown, and `TaskFailedException`s and `RemoteException`s are replaced
+by the original exceptions that caused them.
+
+See [`original_exception`] and [`onlyfirst_exception`](@ref).
+"""
+macro userfriendly_exceptions(expr)
+    quote
+        try
+            $(esc(expr))
+        catch err
+            rethrow(original_exception(onlyfirst_exception(err)))
+        end
+    end
+end
+export @userfriendly_exceptions