class org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager extends java.lang.Object
{
private static final org.eclipse.collections.api.block.function.Function NEW_LOCK;
private final org.eclipse.collections.api.map.ConcurrentMutableMap locks;
private void <init>()
{
org.eclipse.collections.impl.map.mutable.ConcurrentHashMap v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.eclipse.collections.impl.map.mutable.ConcurrentHashMap: org.eclipse.collections.impl.map.mutable.ConcurrentHashMap newMap()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager: org.eclipse.collections.api.map.ConcurrentMutableMap locks> = v;
return;
}
public java.lang.Object getLock(java.lang.Object)
{
org.eclipse.collections.api.map.ConcurrentMutableMap v;
org.eclipse.collections.api.block.function.Function v;
java.lang.Object v, v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager;
v := @parameter: java.lang.Object;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager: org.eclipse.collections.api.map.ConcurrentMutableMap locks>;
v = <org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager: org.eclipse.collections.api.block.function.Function NEW_LOCK>;
v = interfaceinvoke v.<org.eclipse.collections.api.map.ConcurrentMutableMap: java.lang.Object getIfAbsentPut(java.lang.Object,org.eclipse.collections.api.block.function.Function)>(v, v);
return v;
}
static org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager newManager()
{
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager v;
v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager: void <init>()>();
return v;
}
static void <clinit>()
{
org.eclipse.collections.api.block.function.Function v;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager$lambda_static_d0dc6479_1__12: org.eclipse.collections.api.block.function.Function bootstrap$()>();
<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$KeyLockManager: org.eclipse.collections.api.block.function.Function NEW_LOCK> = v;
return;
}
}