Class TaskEngineItemsBufferTest

java.lang.Object
de.hybris.platform.task.impl.TaskEngineItemsBufferTest

@UnitTest public class TaskEngineItemsBufferTest extends Object
  • Constructor Details

    • TaskEngineItemsBufferTest

      public TaskEngineItemsBufferTest()
  • Method Details

    • setUp

      public void setUp()
    • shouldExpireAfterGivenDuration

      public void shouldExpireAfterGivenDuration() throws InterruptedException
      Throws:
      InterruptedException
    • shouldBeAlwaysExpiredWhenIntervalIsZero

      public void shouldBeAlwaysExpiredWhenIntervalIsZero()
    • shouldBeAlwaysExpiredWhenIntervalIsNegative

      public void shouldBeAlwaysExpiredWhenIntervalIsNegative()
    • shouldBeAlwaysExpiredWhenIntervalIsNull

      public void shouldBeAlwaysExpiredWhenIntervalIsNull()
    • shouldBeExpiredWhenDurationChangedToNull

      public void shouldBeExpiredWhenDurationChangedToNull()
    • shouldBeExpiredWhenDurationChangedToZero

      public void shouldBeExpiredWhenDurationChangedToZero()
    • shouldBeExpiredWhenDurationChangedToNegativeValue

      public void shouldBeExpiredWhenDurationChangedToNegativeValue()
    • shouldBeNotExpiredWhenDurationChangedFromZeroToPositiveValue

      public void shouldBeNotExpiredWhenDurationChangedFromZeroToPositiveValue()
    • shouldProvideRequestedNumberOfTasksWhenMoreIsAvailable

      public void shouldProvideRequestedNumberOfTasksWhenMoreIsAvailable()
    • shouldProvideAvailableNumberOfTasksWhenLessThanRequestedIsAvailable

      public void shouldProvideAvailableNumberOfTasksWhenLessThanRequestedIsAvailable()
    • shouldntProvideTasksWhenBufferIsEmpty

      public void shouldntProvideTasksWhenBufferIsEmpty()
    • shouldntProvideTasksWhenSetToNull

      public void shouldntProvideTasksWhenSetToNull()
    • shouldntBeReadedFullyByConsecutiveReads

      public void shouldntBeReadedFullyByConsecutiveReads()
    • shouldntBeReadedFullyAndConsistentlyByMultipleThreads

      public void shouldntBeReadedFullyAndConsistentlyByMultipleThreads() throws InterruptedException
      Throws:
      InterruptedException