Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
He visto un programa de Apache Flink de una clase que implementa SinkFunction que carga periódicamente los datos sin un primitivo de sincronización adecuado. ¿Se considera peligroso? Dado que la api lee “Escribe el valor dado en el sink. Esta función se llama para cada registro”. Asumo que la función . . . Read more
En mi constructor de clase, creo un ejecutor: scheduledExecutorService = Executors.newScheduledThreadPool( ARGUMENTS.size(), ExecutorServiceUtils.createThreadFactory(“process-%d”)); Tengo un conjunto llamado ARGUMENTS que contiene 5 ArgumentTypes (un enum) (ARG1, ARG2, ARG3, ARG4, ARG5). Programo un trabajo periódico para cada uno: for (ArgumentType arg : ARGUMENT_TYPES) { scheduledExecutorService.scheduleAtFixedRate(() -> work(arg), SCHEDULED_TASK_INITIAL_DELAY_MILLIS, 1L, TimeUnit.MILLISECONDS); } Luego . . . Read more
Necesito paralelizar nuestras llamadas para enviar mensajes de texto para poder enviar más de uno al mismo tiempo. Tenemos una cuenta de Twilio existente desde hace mucho tiempo. Cuando intento paralelizar la llamada para enviar un texto, obtengo una excepción de “Too Many Requests” de Twilio.Exceptions.ApiExceptions (429) https://www.twilio.com/docs/api/errors/20429. Este es . . . Read more
Estoy intentando ejecutar una demostración de Beautiful Soup para extraer precios de Ebay y los precios están en USD, pero por alguna razón, cuando extraigo los precios, se convierten automáticamente en NT$. No estoy seguro de qué está sucediendo. Intenté ir al sitio del Reino Unido y se imprime la . . . Read more
Tengo un canal: aChan := make(chan struct{}) y una duración de tiempo limite var t time.Duration. Quiero que el programa termine si el canal está cerrado o si se alcanza el tiempo limite t ,siempre y cuando t sea una duración positiva. Sé que puedo usar un bucle if else . . . Read more