本文整理了Java中com.palantir.atlasdb.transaction.api.TransactionManager.getLockService()
方法的一些代码示例,展示了TransactionManager.getLockService()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TransactionManager.getLockService()
方法的具体详情如下:
包路径:com.palantir.atlasdb.transaction.api.TransactionManager
类名称:TransactionManager
方法名:getLockService
[英]Returns the lock service used by this transaction manager.
[中]返回此事务管理器使用的锁定服务。
代码示例来源:origin: palantir/atlasdb
@Override
public LockService getLockService() {
assertOpen();
return txManager.getLockService();
}
代码示例来源:origin: palantir/atlasdb
public static BackgroundSweeperImpl create(
MetricsManager metricsManager,
AdjustableSweepBatchConfigSource sweepBatchConfigSource,
Supplier<Boolean> isSweepEnabled,
Supplier<Integer> sweepThreads,
Supplier<Long> sweepPauseMillis,
Supplier<SweepPriorityOverrideConfig> sweepPriorityOverrideConfig,
PersistentLockManager persistentLockManager,
SpecificTableSweeper specificTableSweeper) {
NextTableToSweepProvider nextTableToSweepProvider = NextTableToSweepProvider
.create(specificTableSweeper.getKvs(),
specificTableSweeper.getTxManager().getLockService(),
specificTableSweeper.getSweepPriorityStore());
return new BackgroundSweeperImpl(
metricsManager,
specificTableSweeper.getTxManager().getLockService(),
nextTableToSweepProvider,
sweepBatchConfigSource,
isSweepEnabled,
sweepThreads,
sweepPauseMillis,
sweepPriorityOverrideConfig,
persistentLockManager,
specificTableSweeper);
}
代码示例来源:origin: palantir/atlasdb
txManager.getLockService(),
NextTableToSweepProvider.create(kvs,
txManager.getLockService(),
specificTableSweeper.getSweepPriorityStore()),
sweepBatchConfigSource,
代码示例来源:origin: com.palantir.atlasdb/atlasdb-impl-shared
@Override
public LockService getLockService() {
assertOpen();
return txManager.getLockService();
}
代码示例来源:origin: com.palantir.atlasdb/atlasdb-impl-shared
public static BackgroundSweeperImpl create(
MetricsManager metricsManager,
AdjustableSweepBatchConfigSource sweepBatchConfigSource,
Supplier<Boolean> isSweepEnabled,
Supplier<Integer> sweepThreads,
Supplier<Long> sweepPauseMillis,
Supplier<SweepPriorityOverrideConfig> sweepPriorityOverrideConfig,
PersistentLockManager persistentLockManager,
SpecificTableSweeper specificTableSweeper) {
NextTableToSweepProvider nextTableToSweepProvider = NextTableToSweepProvider
.create(specificTableSweeper.getKvs(),
specificTableSweeper.getTxManager().getLockService(),
specificTableSweeper.getSweepPriorityStore());
return new BackgroundSweeperImpl(
metricsManager,
specificTableSweeper.getTxManager().getLockService(),
nextTableToSweepProvider,
sweepBatchConfigSource,
isSweepEnabled,
sweepThreads,
sweepPauseMillis,
sweepPriorityOverrideConfig,
persistentLockManager,
specificTableSweeper);
}
代码示例来源:origin: com.palantir.atlasdb/atlasdb-tests-shared
txManager.getLockService(),
NextTableToSweepProvider.create(kvs,
txManager.getLockService(),
specificTableSweeper.getSweepPriorityStore()),
sweepBatchConfigSource,
内容来源于网络,如有侵权,请联系作者删除!