Java генерирует параллельные проблемы IntStream (и других потоков) - PullRequest
Новая
       19

Java генерирует параллельные проблемы IntStream (и других потоков)

0 голосов
/ 27 апреля 2018 
public static void main(String[] args) throws Throwable {
    AtomicInteger i = new AtomicInteger();
    IntStream
            .generate(
                    () -> {
                        int item = i.incrementAndGet();
                        System.out.println("[generator]： "
                                + Thread.currentThread().getName()
                                + ", item:" + item);
                        return item;
                    })
            .limit(5)
            .parallel()
            .forEach(
                    item -> {
                        System.out.println("[consumer]: "
                                + Thread.currentThread().getName()
                                + ", item:" + item);
                    });
}

На мой взгляд, генератор должен вызывать 5 (лимит) раз, а потребитель должен выполнять в несколько потоков, но генератор вызывается 512 раз. и потребитель, выполняющий в той же теме, любой может объяснить мне его ошибка или я не правильно использую способ?

выходы: [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 3 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 5 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 6 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 7 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 8 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 9 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 10 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 4 [генератор]: основной, предмет: 2 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 1 [генератор] ： основной, предмет: 13 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 12 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 11 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 16 [генератор]: основной, предмет: 15 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 14 [генератор] ： основной, предмет: 19 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 18 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 17 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 22 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 24 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 25 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 26 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 27 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 28 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 29 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 30 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 31 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 32 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 33 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 34 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 35 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 36 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 37 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 38 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 39 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 40 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 41 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 42 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 43 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 44 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 45 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 46 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 47 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 48 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 49 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 50 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 51 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 52 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 53 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 54 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 55 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 56 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 57 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 58 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 59 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 60 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 61 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 62 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 63 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 64 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 65 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 66 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 67 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 68 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 69 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 70 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 71 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 72 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 73 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 74 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 75 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 76 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 77 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 78 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 79 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 80 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 81 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 82 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 83 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 84 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 85 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 86 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 87 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 88 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 89 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 90 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 91 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 92 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 93 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 94 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 95 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 96 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 97 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 98 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 99 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 100 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 101 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 102 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 103 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 104 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 105 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 106 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 107 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 108 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 109 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 110 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 111 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 112 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 113 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 114 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 115 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 116 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 117 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 118 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 119 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 120 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 121 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 122 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 123 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 124 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 125 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 126 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 127 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 128 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 129 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 130 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 131 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 132 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 133 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 134 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 135 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 136 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 137 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 138 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 139 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 140 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 141 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 142 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 143 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 144 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 145 [генератор] ： ForkJoinPool.commonPool-worker-2, item: 146 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 4 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 12 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 16 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 18 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 22 * ​​1008 * [генератор]: основной, предмет: 21 [генератор]: главный, элемент: 147 [генератор]: основной, элемент: 148 [генератор] ： основной, элемент: 149 [генератор] ： основной, элемент: 150 [генератор] ： основной, элемент: 151 [генератор]: главный, предмет: 152 [генератор]: главный, предмет: 153 [генератор] ： основной, элемент: 154 [генератор] ： основной, элемент: 155 [генератор] ： основной, элемент: 156 [генератор]: главный, элемент: 157 [генератор]: главный, элемент: 158 [генератор] ： основной, элемент: 159 [генератор] ： основной, элемент: 160 [генератор] ： основной, элемент: 161 [генератор]: главный, элемент: 162 [генератор]: главный, элемент: 163 [генератор] ： основной, элемент: 164 [генератор] ： основной, элемент: 165 [генератор] ： основной, элемент: 166 [генератор]: главный, элемент: 167 [генератор]: главный, элемент: 168 [генератор] ： основной, элемент: 169 [генератор] ： основной, элемент: 170 [генератор] ： основной, элемент: 171 [генератор]: главный, предмет: 172 [генератор]: главный, предмет: 173 [генератор] ： основной, элемент: 174 [генератор] ： основной, элемент: 175 [генератор] ： основной, элемент: 176 [генератор]: главный, предмет: 177 [генератор]: главный, предмет: 178 [генератор] ： основной, элемент: 179 [генератор] ： основной, элемент: 180 [генератор] ： основной, элемент: 181 [генератор]: главный, предмет: 182 [генератор]: главный, предмет: 183 [генератор] ： основной, элемент: 184 [генератор] ： основной, элемент: 185 [генератор] ： основной, элемент: 186 [генератор]: главный, элемент: 187 [генератор]: основной, элемент: 188 [генератор] ： основной, элемент: 189 [генератор] ： основной, элемент: 190 [генератор] ： основной, элемент: 191 [генератор]: главный, элемент: 192 [генератор]: главный, элемент: 193 [генератор] ： основной, элемент: 194 [генератор] ： основной, элемент: 195 [генератор] ： основной, элемент: 196 [генератор]: главный, элемент: 197 [генератор]: главный, элемент: 198 [генератор] ： основной, элемент: 199 [генератор] ： основной, элемент: 200 [генератор] ： основной, элемент: 201 [генератор]: главный, предмет: 202 [генератор]: главный, предмет: 203 [генератор] ： основной, элемент: 204 [генератор] ： основной, элемент: 205 [генератор] ： основной, элемент: 206 [генератор]: главный, предмет: 207 [генератор]: главный, предмет: 208 [генератор] ： основной, элемент: 209 [генератор] ： основной, элемент: 210 [генератор] ： основной, элемент: 211 [генератор]: главный, предмет: 212 [генератор]: главный, предмет: 213 [генератор] ： основной, элемент: 214 [генератор] ： основной, элемент: 215 [генератор] ： основной, элемент: 216 [генератор]: главный, предмет: 217 [генератор]: главный, предмет: 218 [генератор] ： основной, элемент: 219 [генератор] ： основной, элемент: 220 [генератор] ： основной, элемент: 221 [генератор]: основной, элемент: 222 [генератор]: основной, элемент: 223 [генератор] ： основной, элемент: 224 [генератор] ： основной, элемент: 225 [генератор] ： основной, элемент: 226 [генератор]: главный, предмет: 227 [генератор]: главный, предмет: 228 [генератор] ： основной, элемент: 229 [генератор] ： основной, элемент: 230 [генератор] ： основной, элемент: 231 [генератор]: главный, предмет: 232 [генератор]: главный, предмет: 233 [генератор] ： основной, элемент: 234 [генератор] ： основной, элемент: 235 [генератор] ： основной, элемент: 236 [генератор]: главный, предмет: 237 [генератор]: главный, предмет: 238 [генератор] ： основной, элемент: 239 [генератор] ： основной, элемент: 240 [генератор] ： основной, элемент: 241 [генератор]: главный, элемент: 242 [генератор]: главный, элемент: 243 [генератор] ： основной, элемент: 244 [генератор] ： основной, элемент: 245 [генератор] ： основной, элемент: 246 [генератор]: главный, элемент: 247 [генератор]: главный, элемент: 248 [генератор] ： основной, элемент: 249 [генератор] ： основной, элемент: 250 [генератор] ： основной, элемент: 251 [генератор]: главный, элемент: 252 [генератор]: главный, элемент: 253 [генератор] ： основной, предмет: 254 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 20 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 256 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 257 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 258 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 259 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 260 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 261 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 262 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 263 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 264 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 265 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 266 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 267 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 268 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 269 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 270 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 271 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 272 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 273 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 274 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 275 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 276 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 277 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 278 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 279 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 280 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 281 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 282 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 283 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 284 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 285 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 286 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 287 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 288 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 289 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 290 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 291 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 292 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 293 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 294 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 295 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 296 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 297 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 298 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 299 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 300 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 301 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 302 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 303 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 304 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 305 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 306 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 307 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 308 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 309 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 310 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 311 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 312 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 313 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 314 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 315 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 316 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 317 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 318 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 319 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 320 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 321 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 322 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 323 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 324 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 325 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 326 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 327 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 328 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 329 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 330 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 331 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 332 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 333 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 334 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 335 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 336 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 337 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 338 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 339 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 340 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 341 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 342 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 343 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 344 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 345 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 346 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 347 [генератор]: основной, предмет: 255 [генератор]: главный, элемент: 349 [генератор]: основной, элемент: 350 [генератор] ： основной, элемент: 351 [генератор] ： основной, элемент: 352 [генератор] ： основной, элемент: 353 [генератор]: главный, элемент: 354 [генератор]: основной, элемент: 355 [генератор] ： основной, предмет: 356 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 23 [генератор]: главный, предмет: 357 [генератор]: главный, предмет: 359 [генератор] ： основной, предмет: 360 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 348 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 362 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 363 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 364 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 365 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 366 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 367 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 368 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 369 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 370 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 371 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 372 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 373 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 374 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 375 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 376 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 377 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 378 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 379 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 380 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 381 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 382 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 383 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 384 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 385 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 386 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 387 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 388 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 389 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 390 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 391 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 392 [генератор] ： ForkJoinPool.commonPool-worker-1, предмет: 393 [генератор]: основной, предмет: 361 [генератор]: главный, предмет: 394 [генератор]: главный, предмет: 395 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 358 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 396 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 397 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 398 [генератор] ： ForkJoinPool.commonPool-работник-3, предмет: 399 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 400 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 401 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 402 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 403 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 404 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 405 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 406 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 407 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 408 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 409 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 410 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 411 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 412 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 413 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 414 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 415 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 416 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 417 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 418 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 419 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 420 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 421 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 422 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 423 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 424 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 425 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 426 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 427 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 428 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 429 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 430 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 431 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 432 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 433 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 434 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 435 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 436 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 437 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 438 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 439 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 440 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 441 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 442 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 443 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 444 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 445 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 446 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 447 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 448 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 449 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 450 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 451 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 452 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 453 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 454 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 455 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 456 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 457 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 458 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 459 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 460 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 461 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 462 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 463 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 464 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 465 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 466 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 467 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 468 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 469 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 470 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 471 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 472 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 473 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 474 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 475 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 476 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 477 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 478 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 479 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 480 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 481 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 482 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 483 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 484 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 485 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 486 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 487 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 488 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 489 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 490 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 491 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 492 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 493 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 494 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 495 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 496 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 497 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 498 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 499 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 500 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 501 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 502 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 503 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 504 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 505 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 506 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 507 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 508 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 509 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 510 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 511 [генератор] ： ForkJoinPool.commonPool-worker-3, предмет: 512

Ответы [ 4 ]

0 голосов
/ 27 апреля 2018

Это хороший вопрос, но как-то очень плохо объяснил. Давайте упростим это: 

    AtomicInteger i = new AtomicInteger(0);
    AtomicInteger count = new AtomicInteger(0);
    IntStream.generate(() -> i.incrementAndGet())
            .parallel()
            .peek(x -> count.incrementAndGet())
            .limit(5)
            .forEach(System.out::println);

    System.out.println("count = " + count);

Работает в java-8, действительно печатает 512 на моей машине (довольно постоянно), но дело в том, что, поскольку вы используете неупорядоченный поток через generate, limit свободен принимать любую часть / ценности по своему усмотрению; поэтому, когда вы говорите, что, по вашему мнению, генератор вызывается только 5 раз, это неправильно. Он вызывается любое количество раз, когда реализация потока ощущается как.

В то же время java-10 действительно запускает генератор (Supplier) гораздо реже (это не всегда 5), поэтому, вероятно, произошел внутренний переход на более быстрое замыкать операции или отменить задачи, которые уже рассматривались.

0 голосов
/ 27 апреля 2018

После выполнения вашего кода несколько раз, это то, что я наблюдал:

  • i.incrementAndGet() выполняется случайное количество раз. Вот некоторые подсчеты: 384, 256, 128, 768, 640, 896, 1024. Но число раз, которое вызывается этим методом, всегда делится на 8. Вовлечено 8 потоков.
  • forEach всегда выбирает один поток случайным образом (это может быть основной поток или другой поток пула ForkJoin) и печатает его элементы. Независимо от того, что вы делаете, он заказан.

Я думаю, что API работает правильно, поскольку IntStream.generate больше подходит для генерации случайных чисел, и фактически это то, что он делает. Это Javadoc описание:

Возвращает бесконечный последовательный неупорядоченный поток, где каждый элемент генерируется предоставленным {@code IntSupplier}. Это подходит для генерация постоянных потоков, потоков случайных элементов и т. д.

Это тест, который я использовал для проверки поведения: 

IntStream.range(0, 20).forEach(c -> {
    AtomicInteger i = new AtomicInteger();
    IntStream
            .generate(
                    () -> {
                        int item = i.incrementAndGet();
//                            System.out.println("[generator]： "
//                                    + Thread.currentThread().getName()
//                                    + ", item:" + item);
                        return item;
                    })
            .limit(5)
            .parallel()
            .forEach(
                    item -> {
                        System.out.println("[consumer]: "
                                + Thread.currentThread().getName()
                                + ", item:" + item);
                    });
    System.out.println(i);
    System.out.println(i.intValue() % 8);
});

Я бы посоветовал запускать ваш код несколько раз, чтобы получить более полное представление о происходящем. Не совсем верно, что генератор вызывается 512 раз.

0 голосов
/ 27 апреля 2018

Спасибо всем, я проверил в Java 10.0.1: 1. Код будет работать в нескольких потоках (поэтому java 8 должен работать с ошибкой в ​​одном потоке, и исправлен в 10.0.1) 2. Генератор вызывается 9 раз (тест в Intellj, его случайный выбор), потому что несколько потоков извлекают элементы, а другой поток обрабатывает, а потоки данных не выполняют ограничение

[генератор] ： основной, элемент: 1 [генератор] ： ForkJoinPool.commonPool-worker-2, предмет: 3 [потребитель]: основной, предмет: 1 [генератор] ： ForkJoinPool.commonPool-worker-4, предмет: 2 [генератор] ： ForkJoinPool.commonPool-worker-13, предмет: 6 [генератор]: основной, предмет: 5 [генератор] ： ForkJoinPool.commonPool-worker-11, предмет: 4 [потребитель]: ForkJoinPool.commonPool-worker-2, предмет: 3 [потребитель]: основной, предмет: 5 [генератор] ： ForkJoinPool.commonPool-worker-6, предмет: 9 [потребитель]: ForkJoinPool.commonPool-worker-13, предмет: 6 [генератор] ： ForkJoinPool.commonPool-worker-15, item: 8 [потребитель]: ForkJoinPool.commonPool-worker-4, предмет: 2 [генератор] ： ForkJoinPool.commonPool-worker-9, предмет: 7

0 голосов
/ 27 апреля 2018

Просто дикая догадка, так как я не настолько знаком с техническими деталями:

Существует пул потоков. Если есть работа, и свободная нить доступна, возможно, используется re . Генератор и Потребитель могут использовать одни и те же потоки, но это происходит независимо друг от друга.

Поскольку состояние Instream-javadocs IntStream.generate, по-видимому, возвращает [..] бесконечный последовательный неупорядоченный поток , что бы это ни значило. Я предполагаю, что он просто прекращает генерировать значения, так как из-за цикла сбора мусора, который обнаруживает, что никто больше не заинтересован в результатах.

Может быть IntStream.range(0, 5) это то, что вы ищете. Это также устраняет необходимость использования атомного целого числа и побочных эффектов функции.

...