Module org.apache.jena.arq

Package org.apache.jena.system

Class ThreadTxn

java.lang.Object

org.apache.jena.system.ThreadTxn

public class ThreadTxn
extends Object

An action that will happen on a different thread later when ThreadAction.run() is called. A thread is created and the transaction started during a call to the creation operations threadTxnRead(org.apache.jena.sparql.core.Transactional, java.lang.Runnable) or threadTxnWrite(org.apache.jena.sparql.core.Transactional, java.lang.Runnable). The associated Runnable is called and the transaction completed when ThreadAction.run() is called. Being on a thread, the state of the world the forked transaction sees is outside the creating thread which may itself be in a transaction. Warning: creating a write transaction inside a write transaction will cause deadlock.

Constructor Summary

Constructors

Constructor	Description
ThreadTxn()

Method Summary

Modifier and Type	Method	Description
static ThreadAction	threadTxn(Transactional trans, TxnType txnType, Runnable action)	Create a thread-backed delayed transaction action.
static ThreadAction	threadTxnRead(Transactional trans, Runnable action)	Create a thread-backed delayed READ transaction action.
static ThreadAction	threadTxnWrite(Transactional trans, Runnable action)	Create a thread-backed delayed WRITE action.
static ThreadAction	threadTxnWriteAbort(Transactional trans, Runnable action)	Create a thread-backed delayed WRITE-abort action (mainly for testing).

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ThreadTxn

public ThreadTxn()

Method Details

threadTxn

public static ThreadAction threadTxn(Transactional trans,
 TxnType txnType,
 Runnable action)

Create a thread-backed delayed transaction action. Call ThreadAction.run() to perform the read transaction.

threadTxnRead

public static ThreadAction threadTxnRead(Transactional trans,
 Runnable action)

Create a thread-backed delayed READ transaction action. Call ThreadAction.run() to perform the read transaction.

threadTxnWrite

public static ThreadAction threadTxnWrite(Transactional trans,
 Runnable action)

Create a thread-backed delayed WRITE action. Call ThreadAction.run() to perform the write transaction. (If called from inside a write transaction on the trans, this will deadlock.)

threadTxnWriteAbort

public static ThreadAction threadTxnWriteAbort(Transactional trans,
 Runnable action)

Create a thread-backed delayed WRITE-abort action (mainly for testing).