db-queue：在Java和数据库之上的worker-queue实现 （121个子文件） 
gradlew.bat 3KB CODEOWNERS 38B .gitattributes 22B .gitignore 113B build.gradle 4KB dependencies.gradle 1KB gradlew 6KB jenkins_jobs.groovy 25B
gradle-wrapper.jar 58KB QueueConfigsReader.java 22KB QueueConfigsReaderTest.java 19KB QueueServiceTest.java 15KB QueueSettings.java 13KB QueueService.java 12KB Oracle11QueuePickTaskDao.java 10KB QueuePickTaskDaoTest.java 10KB QueueDaoTest.java 9KB Task.java 8KB TaskRecord.java 8KB QueueExecutionPoolTest.java 7KB TaskProcessorTest.java 7KB QueueLoopTest.java 7KB QueueTableSchema.java 7KB ReenqueueRetryStrategy.java 7KB PostgresQueuePickTaskDao.java 7KB MssqlQueuePickTaskDao.java 7KB ReenqueueRetrySettings.java 7KB OracleDatabaseInitializer.java 6KB QueueExecutionPool.java 6KB MssqlDatabaseInitializer.java 6KB PostgresDatabaseInitializer.java 6KB Oracle11QueueDao.java 6KB QueueRunnerFactoryTest.java 6KB TaskPickerTest.java 6KB MssqlQueueDao.java 6KB PostgresQueueDao.java 6KB EnqueueParams.java 5KB ReenqueueRetryStrategyTest.java 5KB TaskExecutionResult.java 5KB TaskResultHandlerTest.java 5KB QueueLoop.java 5KB LoopPolicy.java 5KB QueueRunner.java 4KB QueueLocation.java 4KB TaskProcessor.java 4KB QueueRunnerInExternalExecutorTest.java 4KB QueueRunnerInTransactionTest.java 4KB TaskPicker.java 4KB ReenqueueRetryType.java 4KB TaskLifecycleListener.java 3KB ExampleConfiguration.java 3KB ArchitectureTest.java 3KB QueueShard.java 3KB QueueRunnerInSeparateTransactionsTest.java 3KB QueueDao.java 3KB TaskResultHandler.java 3KB QueuePickTaskDao.java 3KB ProcessingMode.java 2KB ThreadLifecycleListener.java 2KB QueueThreadFactory.java 2KB QueueRunnerInTransaction.java 2KB BaseQueueRunner.java 2KB TimeLimiter.java 2KB StringQueueProducer.java 2KB DefaultOracle11QueuePickTaskDaoTest.java 2KB QueueConfig.java 2KB CustomOracle11QueuePickTaskDaoTest.java 2KB NoopTaskLifecycleListener.java 2KB QueueTableSchemaTest.java 2KB QueueRunnerInExternalExecutor.java 1KB TimeLimiterTest.java 1KB FakeQueueConsumer.java 1KB QueueRunnerInSeparateTransactions.java 1KB QueueConsumer.java 1KB DefaultOracle11QueueDaoTest.java 1KB CustomOracle11QueueDaoTest.java 1KB DefaultPostgresQueuePickTaskDaoTest.java 1KB PickTaskSettings.java 1KB CustomPostgresQueuePickTaskDaoTest.java 1KB DefaultMssqlQueuePickTaskDaoTest.java 1KB CustomMssqlQueuePickTaskDaoTest.java 1KB NoopThreadLifecycleListener.java 1KB ReenqueueRetrySettingsTest.java 1KB DefaultPostgresWithSequenceQueueDaoTest.java 1KB DefaultMssqlWithSequenceQueueDaoTest.java 1KB QueueId.java 1KB QueueShardId.java 1KB QueueLocationTest.java 1007B StringQueueConsumer.java 965B NoopPayloadTransformer.java 964B TaskRetryType.java 866B DirectExecutor.java 835B QueueProducer.java 782B DefaultPostgresQueueDaoTest.java 774B CustomPostgresQueueDaoTest.java 769B DefaultMssqlQueueDaoTest.java 768B CustomMssqlQueueDaoTest.java 763B TaskPayloadTransformer.java 760B MillisTimeProvider.java 689B NoopQueueConsumer.java 629B共 121 条
- 1
- 2
资源评论
咔丫咔契
- 粉丝: 24
- 资源: 4543
