File tree 1 file changed +0
-16
lines changed
util/src/test/java/io/kubernetes/client/informer/cache 1 file changed +0
-16
lines changed Original file line number Diff line number Diff line change @@ -67,22 +67,6 @@ public void testListenerAddition() throws InterruptedException {
67
67
public void testShutdownGracefully () throws InterruptedException {
68
68
SharedProcessor <V1Pod > sharedProcessor =
69
69
new SharedProcessor <>(Executors .newCachedThreadPool (), Duration .ofSeconds (5 ));
70
- TestWorker <V1Pod > quickWorker = new TestWorker <>(null , 0 );
71
- quickWorker .setTask (
72
- () -> {
73
- try {
74
- // sleep 2s so that it could terminate within timeout(5s)
75
- Thread .sleep (2000 );
76
- } catch (InterruptedException e ) {
77
- }
78
- });
79
- long before = System .currentTimeMillis ();
80
- sharedProcessor .addAndStartListener (quickWorker );
81
- sharedProcessor .stop ();
82
- // the stopping worker properly blocks the processor's stop call
83
- assertTrue (System .currentTimeMillis () - before >= 2000 );
84
-
85
- sharedProcessor = new SharedProcessor <>(Executors .newCachedThreadPool (), Duration .ofSeconds (5 ));
86
70
TestWorker <V1Pod > slowWorker = new TestWorker <>(null , 0 );
87
71
final boolean [] interrupted = {false };
88
72
slowWorker .setTask (
You can’t perform that action at this time.
0 commit comments