0
ответов

Актеры Akka, Futures, и замыкания

Я читал в документации Akka, что опасно закрывать var iables от окружающего актера. Предупреждение. В этом случае вам нужно тщательно избегать закрытия ссылки на содержащий актор, т.е....
вопрос задан: 21 June 2012 15:11
0
ответов

Получить статус std::future

Можно ли проверить завершен ли std::future или нет? Насколько я могу судить, единственный способ сделать это - вызвать wait_for с нулевой продолжительностью и проверить, готов ли статус или нет, но ...
вопрос задан: 5 June 2012 00:59
0
ответов

понимание фьючерсов Clojure

Я пытаюсь понять фьючерсы Clojure, и я видел примеры из общих книг по Clojure, и есть примеры, где фьючерсы используются для параллельных вычислений (что, кажется, делает ...
вопрос задан: 14 May 2012 18:56
0
ответов

std::async использует тот же поток, и мой код не обеспечивает параллелизма.

Я использую C++11 в Mac OS Xcode 4.3.2. std::async использует тот же поток, и мой код не обеспечивает параллелизма. В приведенном ниже примере кода я хочу создать 10 новых потоков. В каждом потоке я хочу вычислить...
вопрос задан: 14 May 2012 15:08
0
ответов

Количество асинхронных/фьючерсов в C++11

Я пробую программу:#include #включить <поток> #include int foo (){ return 0; } int main (int argc, char *argv[] ){ for (auto i = 0L; я < 10000; ++i ){...
вопрос задан: 6 May 2012 16:55
0
ответов

Замена std::async собственной версией, но где должен работать std::promise?

Я использую vc2011, и оказалось, что std::async(std::launch::async,... )немного глючит (иногда не порождает новые потоки и запускает их параллельно, но вместо этого повторно использует потоки и запускает задачу...
вопрос задан: 30 April 2012 00:13
0
ответов

Java Concurrency :Как во время обработки определить, какое Future принадлежит какому Callable?

У меня есть коллекция Callables и ExecutorService. Когда я вызываю All, я получаю список объектов Future. Как я могу определить, какой объект Future сопоставлен с каким Callable до того, как Future завершится?...
вопрос задан: 24 April 2012 19:38
0
ответов

Можно ли выполнять каждую итерацию цикла for/for_each параллельно? (C++11)

Я перебираю вектор структур и обрабатываю каждую структуру по отдельности. Это выглядит примерно так: for_each(begin(data),end(data),DoTask); // предположим, что "данные" — это std::vector //...
вопрос задан: 14 April 2012 17:00
0
ответов

Различия между C# async и Java ExecutorService

C# имеет классную новую функцию public Task async f() { строка r = LongCompute(); вернуть р; } но разве это не эквивалентно public Future f() { return Globals....
вопрос задан: 28 March 2012 08:50
0
ответов

future.isDone возвращает false, даже если задача выполнена

У меня сложная ситуация, Future.isDone() возвращает false, даже если поток выполнен. импортировать java.util.ArrayList; импортировать java.util.LinkedList; импортировать java.util.List; import java.util.concurrent....
вопрос задан: 9 March 2012 19:33
0
ответов

Параллельная генерация случайных чисел с помощью Akka Futures

Я пишу, интенсивно использующий процессор приложение, созданное с помощью Akka 2 Futures. В настоящее время мне не нужны Актеры, но я не отказываюсь их использовать. Несколько вычислений, заключенных в фьючерсах, должны вызывать случайный...
вопрос задан: 7 March 2012 10:54
0
ответов

Утилита метода Future.cancel (boolean)

Я просто изучал пакет java.util.concurrent. Я узнал, что у класса Future есть метод boolean cancel (boolean mayInterruptIfRunning). Прилагаю тестовый код, который я написал: ...
вопрос задан: 2 March 2012 16:11
0
ответов

std :: async - std :: launch :: async | std :: launch :: deferred

Я понимаю, что std :: async делает со следующими параметрами. std :: launch :: async std :: launch :: deferred Что же происходит с std :: launch :: async | std :: launch :: deferred?
вопрос задан: 20 February 2012 11:07
0
ответов

Поведение future.get с таймаутом 0

Может ли кто-нибудь указать мне на какую-то документацию, в которой ясно указано, что Future.get с таймаутом 0 ждать не будет? Документация API для java.util.concurrent.Future не указывает явным образом поведение ...
вопрос задан: 17 February 2012 17:41
0
ответов

Параллелизм - прерывание будущего без его отмены

Есть ли способ прервать будущее, не отменяя его? java doc API: boolean cancel (boolean mayInterruptIfRunning) Пытается отменить выполнение этой задачи. Эта попытка не удастся, если ...
вопрос задан: 17 January 2012 21:28
0
ответов

Исключение во время выполнения Callable

У меня есть следующий Callable: открытый класс Worker реализует Callable {@Override public Boolean call () {boolean успех = правда; // что-то делаем return success; ...
вопрос задан: 7 December 2011 15:31
0
ответов

Почему мои scala-фьючерсы не более эффективны?

Я запускаю этот scala-код в 32-битной четырехъядерной системе Core2: задание def (i: Int, s: Int): Long = {val r = (от i до 500000000 с) .map (_. ToLong) .foldLeft (0L) (_ + _) println ("Задание" + i + "выполнено") r } import ...
вопрос задан: 27 November 2011 15:26
0
ответов

разветвляется и соединяется с использованием постановки задачи Akka

: у меня есть портфель ценных бумаг, которые необходимо обрабатывать параллельно. В Java я использовал пул потоков для обработки каждой безопасности и использовал защелку для обратного отсчета. После завершения I ...
вопрос задан: 10 November 2011 12:50
0
ответов

Реагировать на фьючерсы

Я пытаюсь использовать подход «разделяй и властвуй» (он же вилка / объединение) для решения проблемы вычисления чисел. Вот код: import scala.actors.Futures.future private def compute (input: Input): Result = {...
вопрос задан: 8 November 2011 04:22
0
ответов

Ожидает ли поток блока Scala Future?

Когда я жду результата Scala Future, он ведет себя больше как получение или как реакция, то есть блокирует поток или планирует продолжение после результата, если он доступен ?
вопрос задан: 8 November 2011 04:21
0
ответов

Как вызвать два метода для метода onclick кнопки в HTML или JavaScript?

Как вызвать два метода для метода onclick кнопки в HTML или JavaScript?
вопрос задан: 8 November 2011 04:20
0
ответов

Преимущества актеров над фьючерсами

Я в настоящее время программирую в фьючерсы, и мне довольно любопытно, что такое актеры. Хотелось бы услышать опытный голос: Каковы преимущества актеров перед фьючерсами? Когда я должен использовать одного из них вместо ...
вопрос задан: 8 November 2011 04:17
0
ответов

C ++, Linux: ошибка: запрошено преобразование из «boost :: unique_future » в нескалярный тип «boost :: shared_future ». как это обойти?

Я пытаюсь работать с фьючерсами на ускорение потоков. Итак, как показано здесь, мы можем получить общее будущее из упакованной задачи. Поэтому я пробую такую ​​функцию в linux: template void pool_item (boost :: ...
вопрос задан: 8 November 2011 04:15
0
ответов

Как создать packaged_task с параметрами?

Следуя этому прекрасному руководству по фьючерсам, обещаниям и упакованным задачам, я дошел до того момента, когда я хотел подготовить свою собственную задачу #include #include using ...
вопрос задан: 8 November 2011 04:15
0
ответов

Проектирование Async API в Python

(Примечание: этот вопрос строго о дизайне API, а не о том, как его реализовать; то есть я только забочусь о том, что клиент моего API видит здесь, а не то, что я Приходится делать, чтобы сделать это работать.) В ...
вопрос задан: 2 September 2011 04:54
0
ответов

NHibernate Future Object Graph Many Queries

Дан многоуровневый объектный граф, вызываемый с использованием Future как: var Dads = db.Session.Query () .Where (P => P.EntityKey == Id). var Kids = db ....
вопрос задан: 25 March 2011 19:23
0
ответов

Как мне отменить это задачи, которые выполняются слишком долго с использованием CompletionService

. Я отправляю некоторые будущие задачи с помощью CompletionService, обернутого вокруг 2-х потокового FixedThreadPool ExecutorService, я устанавливаю, затем настраиваю цикл, равный количеству отправленных задач, и использую ...
вопрос задан: 10 March 2011 20:28
0
ответов

Ожидание фактического завершения отмененного будущего

У меня есть SwingWorker, который вызывает некоторый код, который не проверяет прерывание потока. После вызова worker.cancel (true) метод worker.get () немедленно вызовет исключение CancellationException (поскольку ...
вопрос задан: 19 August 2010 13:50