Commits
Henrik Thuesen authored ac7c4e5c6a2
104 104 | pnrs.add(pnr); |
105 105 | return; |
106 106 | } |
107 107 | cached.getAndIncrement(); |
108 108 | } else { |
109 109 | uncached.getAndIncrement(); |
110 110 | } |
111 111 | }); |
112 112 | }); |
113 113 | |
114 - | cbs.shutdown(); |
115 - | cbs.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); // let threads finish... |
116 - | |
117 114 | // wait until backend is drained... |
118 115 | nas.submit(() -> { |
119 116 | while (!transit.isEmpty()) { |
120 117 | nasService |
121 118 | .pullJobs(subscription) |
122 119 | .stream() |
123 120 | .map(NasService.Job::jobId) |
124 121 | .forEach(transit::remove); |
125 122 | try { |
126 123 | Thread.sleep(Long.getLong("rampup.nas.drain.retry", 500)); |
127 124 | } catch (InterruptedException e) { |
128 125 | } |
129 126 | } |
130 127 | }); |
131 128 | |
129 + | cbs.shutdown(); |
130 + | cbs.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); // let threads finish... |
131 + | |
132 132 | nas.shutdown(); |
133 133 | nas.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); |
134 134 | |
135 135 | stat.shutdown(); |
136 136 | stat.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); |
137 137 | |
138 138 | logger.info("Ramp up ended [cached " + cached + ", uncached " + uncached + "]"); |
139 139 | } |
140 - | } |
140 + | } |