QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

CE-936 - Add method withTemporaryContext

Browse Source
This commit is contained in:
darin.kelkhoff
2024-03-12 11:51:10 -05:00
parent d551ad71a6
commit 03f1fc1436
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/context/QContext.java
View File

@ -34,6 +34,7 @@ import com.kingsrook.qqq.backend.core.logging.QLogger;
import com.kingsrook.qqq.backend.core.model.actions.AbstractActionInput; import com.kingsrook.qqq.backend.core.model.actions.AbstractActionInput;
import com.kingsrook.qqq.backend.core.model.metadata.QInstance; import com.kingsrook.qqq.backend.core.model.metadata.QInstance;
import com.kingsrook.qqq.backend.core.model.session.QSession; import com.kingsrook.qqq.backend.core.model.session.QSession;
import com.kingsrook.qqq.backend.core.utils.lambdas.VoidVoidMethod;
import static com.kingsrook.qqq.backend.core.logging.LogUtils.logPair; import static com.kingsrook.qqq.backend.core.logging.LogUtils.logPair;
@ -54,6 +55,7 @@ public class QContext
private static ThreadLocal<Map<String, Serializable>> objectsThreadLocal = new ThreadLocal<>(); private static ThreadLocal<Map<String, Serializable>> objectsThreadLocal = new ThreadLocal<>();
/******************************************************************************* /*******************************************************************************
** private constructor - class is not meant to be instantiated. ** private constructor - class is not meant to be instantiated.
*******************************************************************************/ *******************************************************************************/
@ -105,6 +107,25 @@ public class QContext
/*******************************************************************************
**
*******************************************************************************/
public static void withTemporaryContext(CapturedContext context, VoidVoidMethod method)
{
CapturedContext originalContext = QContext.capture();
try
{
QContext.init(context);
method.run();
}
finally
{
QContext.init(originalContext);
}
}
/******************************************************************************* /*******************************************************************************
** Init a new thread with the context captured from a different thread. e.g., ** Init a new thread with the context captured from a different thread. e.g.,
** when starting some async task. ** when starting some async task.
@ -267,6 +288,7 @@ public class QContext
} }
/******************************************************************************* /*******************************************************************************
** get one named object from the Context for the current thread. may return null. ** get one named object from the Context for the current thread. may return null.
*******************************************************************************/ *******************************************************************************/
@ -280,6 +302,7 @@ public class QContext
} }
/******************************************************************************* /*******************************************************************************
** get one named object from the Context for the current thread, cast to the ** get one named object from the Context for the current thread, cast to the
** specified type if possible. if not found, or wrong type, empty is returned. ** specified type if possible. if not found, or wrong type, empty is returned.