> Если не в многопоточную коллекцию, то куда мемоизировать?

это вопрос формулировки задачи и ограничений. Конкретно представлнную я бы решал вообще без коллекций, голым кодом и переменными в инстансах, на цепочке стримов (нельзя зафакапить переменную несуществующего инстанса, в отличие от несуществующего ключа коллекции)

> Если не в многопоточную коллекцию, то куда мемоизировать?

это вопрос формулировки задачи и ограничений. Конкретно представлнную я бы решал вообще без коллекций, голым кодом и переменными в инстансах, на цепочке стримов (нельзя зафакапить переменную несуществующего инстанса, в отличие от несуществующего ключа коллекции)

я так понял что тут нужно некоторое вычисление, задаваемое некоторым уникальным для этого вычисления ключом, посчитать единожды и не считать больше никогда
некоторые вычисления, при этом, могут зависеть от вычислений по другому ключу
может как сначала прийти запрос по ключу, вычисление которого не зависит от других ключей, а может прийти запрос по другому ключу, вычисление которого зависит от других ключей, а могут прийти запросы конкуррентно

не очень понятно как стримы без хранилища решают задачу ^

может хранить общую ConcurrentHashMap из Key -> CompletableFuture и сабмиттить их на какой-нибудь ForkJoinPool (если вычисления неблокирующие; или просто на пул, если блокирующие)

Всем привет.

Конкарренси — не самая моя сильная сторона, поэтому просьба сильно не кидаться тапками. Я изложу кое какие размышления — поправьте меня пожалуйста, если где ошибся?

Дилемму, с которой я столкнулся, можно описать следующим гистом: https://gist.github.com/skapral/60c041771bf633cbe0befa009be82db1. В реале все вышло несколько сложнее, но гист передает суть.

Есть вычисление B, результат которого зависит от двух A. И B, и А должны быть мемоизированны при первом обращении, и должна быть гарантия что вычисление каждого из doHeavyLifting методов происходит не более одного раза, вне зависимости от того, где и сколько раз их вызвали. При этом клиентская сторона может потенциально вызвать их в рандомном порядке и конкуррентно (сэмулированно в мэйне). Если раннать мэйн из гиста, он будет виснуть с некоторой вероятностью (если B пойдет вычисляться раньше чем обе A, будет дэдлок на ConcurrentHashMapе, даже если тред один).

То что нельзя вкладывать computeIfAbsentы --- я в курсе, вопрос не об этом, в примере вложенные компуты присутствуют только для иллюстрации проблемы. Вопрос в альтернативе.

На данный момент решение видится таким образом: https://gist.github.com/skapral/8545692990383adad26596b2874e6098.

Нет ли каких либо косяков? Можно ли считать memoizedCalculation потокобезопасным? Может можно было решить проще? Я что-то упускаю?

Эта реализация не работает на ubuntu

command = "curl -X GET \"https://api.hitbtc.com/api/2/public/trades/BTCUSD?sort=DESC&by=timestamp&limit=100";
process = Runtime.getRuntime().exec(command);

BufferedReader output = new BufferedReader(new InputStreamReader(process.getInputStream()));
String stream = output.readLine();

JSONArray ordersList = new JSONArray(stream);

вам обязательно сразу считать а не по требованию?

Эта реализация не работает на ubuntu

command = "curl -X GET \"https://api.hitbtc.com/api/2/public/trades/BTCUSD?sort=DESC&by=timestamp&limit=100";
process = Runtime.getRuntime().exec(command);

BufferedReader output = new BufferedReader(new InputStreamReader(process.getInputStream()));
String stream = output.readLine();

JSONArray ordersList = new JSONArray(stream);

Не понял вопрос.

кавычку потерял в команде курла

Не понял вопрос.

у вас в мейне сразу три потока стартуют, но результаты А не нужны пока не запустится Б

хочу узнать что именно из второй реализации не поддерживает убунту, или это моя ошибка в коде

Всем привет.

Конкарренси — не самая моя сильная сторона, поэтому просьба сильно не кидаться тапками. Я изложу кое какие размышления — поправьте меня пожалуйста, если где ошибся?

Дилемму, с которой я столкнулся, можно описать следующим гистом: https://gist.github.com/skapral/60c041771bf633cbe0befa009be82db1. В реале все вышло несколько сложнее, но гист передает суть.

Есть вычисление B, результат которого зависит от двух A. И B, и А должны быть мемоизированны при первом обращении, и должна быть гарантия что вычисление каждого из doHeavyLifting методов происходит не более одного раза, вне зависимости от того, где и сколько раз их вызвали. При этом клиентская сторона может потенциально вызвать их в рандомном порядке и конкуррентно (сэмулированно в мэйне). Если раннать мэйн из гиста, он будет виснуть с некоторой вероятностью (если B пойдет вычисляться раньше чем обе A, будет дэдлок на ConcurrentHashMapе, даже если тред один).

То что нельзя вкладывать computeIfAbsentы --- я в курсе, вопрос не об этом, в примере вложенные компуты присутствуют только для иллюстрации проблемы. Вопрос в альтернативе.

На данный момент решение видится таким образом: https://gist.github.com/skapral/8545692990383adad26596b2874e6098.

Нет ли каких либо косяков? Можно ли считать memoizedCalculation потокобезопасным? Может можно было решить проще? Я что-то упускаю?