Количество потоков, которые могут быть созданы при ожидании значения FUTURE - PullRequest
0 голосов
/ 23 апреля 2020

предположим, что я отправляю сообщения Kk асинхронно в Kafka, и по какой-то причине, скажем, я все еще жду подтверждения для всех сообщений 12k. Тогда, сколько потоков будет создано весенним загрузочным приложением, когда я жду всех подтверждений 12k?

Я просто отправляю фрагмент кода для краткости

     @Service
@Scope("prototype")
public class HelloKafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    String topicName = "t_hello_world";

    int i = 0;

    int counter;
    ListenableFuture<SendResult<String, String>> future = null;

    public List<ListenableFuture<SendResult<String, String>>> sendMessage(String message) {

        List<ListenableFuture<SendResult<String, String>>> cf = new ArrayList<ListenableFuture<SendResult<String, String>>>();

        while (i < 12000) {

            future = kafkaTemplate.send(topicName, message);
            cf.add(future);

            i++;
    future.addCallback( .....  //callback code gioes here .omitted for brevity
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...