materkey-threads #206
materkey-threads #206
Conversation
| private void loop() throws IOException { | ||
| int count = 0; | ||
| final int maxTries = 10; | ||
| int connect_timeout = 200; |
| break; | ||
| } catch (Exception e) { | ||
| if (++count == maxTries) { | ||
| log.error("Can't connect, exiting "); |
| client.loop(); | ||
| } | ||
|
|
||
| private void loop() throws IOException { |
There was a problem hiding this comment.
метод надо разбить на несколько
| try { | ||
| nbytes = in.read(buffer); | ||
| } catch (SocketTimeoutException ste) { | ||
| TimeUnit.MILLISECONDS.sleep(500); |
There was a problem hiding this comment.
в чем логика? клиент уже отвалился
| TimeUnit.SECONDS.sleep(retry_timeout); | ||
| retry_timeout *= 2; | ||
| } catch (InterruptedException e1) { | ||
| e1.printStackTrace(); |
There was a problem hiding this comment.
а почему прерываем слип до ретрая а не попытки коннекта?
| int maxPoolSize = 3; | ||
| final BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(); | ||
|
|
||
| final ThreadPoolExecutor pool = new ThreadPoolExecutor(3, maxPoolSize, 0L, |
| } | ||
| log.info(String.format("Can't connect, try again in %d sec ", retry_timeout)); | ||
| try { | ||
| TimeUnit.SECONDS.sleep(retry_timeout); |
There was a problem hiding this comment.
разрешение маловато, в случае если мы хотим 1 ретрай достаточно быстро на случай рестарта сервера -- не сможем настроить
| log.info(String.format("Can't connect, try again in %d sec ", retry_timeout)); | ||
| try { | ||
| TimeUnit.SECONDS.sleep(retry_timeout); | ||
| retry_timeout *= 2; |
There was a problem hiding this comment.
опционально можно сделать массив с хардкодными значениями и ходить по индексу
| <dependency> | ||
| <groupId>com.google.code.gson</groupId> | ||
| <artifactId>gson</artifactId> | ||
| <version>RELEASE</version> |
There was a problem hiding this comment.
лучше прибить конкретную версию
| @@ -19,6 +20,7 @@ | |||
| /** | |||
| * | |||
| */ | |||
| @Ignore | |||
There was a problem hiding this comment.
лишний дифф лучше убрать
|
баллы поставил |
|
|
||
| public static void main(String[] args) { | ||
| int maxPoolSize = 3; | ||
| final BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(); |
There was a problem hiding this comment.
здесь размер очереди будет Integer.MAX_VALUE.
а что если попробовать реализовать свой блокирующий pool.submit() на этой очереди? будет более прямо
| private int port; | ||
| private AtomicLong serverCounter = new AtomicLong(0); | ||
| private Protocol<Message> protocol; | ||
| private Future[] fut; |
There was a problem hiding this comment.
кто выпиливает отсюда завершенные таски?
| private int maxClientsNum; | ||
|
|
||
|
|
||
| private ConcurrentMap<Long, Worker> workerMap; |
There was a problem hiding this comment.
может попытаться запихать тот future внутрь этой мапы?
No description provided.