WedX - журнал о программировании и компьютерных науках

Управление реализацией потока в JVM

Недавно я работал над развертыванием параллельных объектов на многоядерных процессорах. В примере я использую BlockingQueue.take() метод, в спецификации которого упоминается, что он блокирует. Это означает, что метод не освобождает ресурсы окружающего потока, чтобы их можно было повторно использовать для других параллельных задач. Это полезно, поскольку общее количество активных потоков в экземпляре JVM ограничено, и если приложению потребуются тысячи активных потоков, жизненно важно иметь возможность повторно использовать приостановленные потоки. С другой стороны, JVM использует отображение 1:1 из потоков уровня приложения в потоки уровня ОС в Java; т. е. каждый экземпляр потока Java становится основным потоком уровня ОС.

Текущее решение основано на java.util.concurrency в Java 1.5+. Тем не менее, нам нужны рабочие потоки, которые можно масштабировать до большого количества. Теперь мне интересно найти следующие ответы:

  • Есть ли способ заменить реализацию java.lang.Thread в JVM, чтобы я мог подключить свою собственную реализацию потока?
  • Возможно ли это только путем настройки разделов C++ реализации потока в JVM и его перекомпиляции?
  • Есть ли какая-нибудь библиотека, способная заменить классический поток в Java?
  • Опять же, в той же строке, есть ли библиотека или способ указать, как некоторые потоки в Java могут быть сопоставлены с только одним потоком на уровне ОС?

Я также нашел this, в котором обсуждаются различные реализации JVM, и я не уверен, что они могут помочь .

Спасибо за ваши комментарии и идеи заранее.

java concurrency java.util.concurrent multicore concurrent-programming
20.07.2011

  • У меня есть один вопрос: что пытается сделать в целом? Возможно, это поможет найти хороший ответ. 21.07.2011
  • если вас беспокоит BlockingQueue.take() или блокировка в целом, вы можете переписать эту часть кода, чтобы использовать неблокировку с использованием условия (также в java.util.concurrent), посмотреть, есть ли объект, если нет объекта , вы можете await. Всякий раз, когда объект помещается в очередь, вы можете «сигнализировать» любому ожидающему потоку... это может быть не так просто, как кажется, но опять же, это будет проще, чем писать код для вашего собственные темы 21.07.2011
  • @chris-jester-young В целом каждый объект использует внутренний ExecutorService вместе с хранилищем асинхронных сообщений, хранящихся в объекте. Служба ES постоянно take()s получает очередное сообщение из репо и пытается его запустить. Проблема в том, что мы хотим, чтобы объект использовал единственный поток выполнения, поэтому, когда поток для take() не освобождается, мы сталкиваемся с этой проблемой, чтобы иметь другой отдельный поток для фактического выполнения сообщения. . Пожалуйста, дайте мне знать, если требуется дополнительная разработка. 21.07.2011
  • @cahuistle Спасибо за ваш комментарий. Я рассмотрю ваше предложение. Я не уверен, освобождает ли await() ресурсы прилагаемого потока. Под блокировкой подразумевается, что нам нужно полностью отсоединить поток для повторного использования для другого выполнения. 21.07.2011

Ответы:


1

Если вы создаете тысячи потоков, вы делаете это неправильно.

Вместо этого рассмотрите возможность использования платформы Executor. (Начните с классов Executors и ThreadPoolExecutor.) Они позволяют ставить в очередь тысячи задач, имея разумное количество потоков, обрабатывающих их.

Я предполагаю, что этот подход - это то, что вы имели в виду под «библиотекой для замены классических потоков». Я настоятельно рекомендую вам изучить исполнителей.

Одно предостережение: исполнители по умолчанию используют потоки, не являющиеся демонами. Таким образом, вы должны закрыть свой исполнитель, когда закончите с ним. Вы можете сделать это при выходе из программы, если есть нормальный способ выхода из вашей программы, который не включает просто ожидание завершения всех потоков. :-)

20.07.2011
  • На самом деле текущее решение основано на java.util.concurrency в Java 1.5+. Тем не менее, нам нужны рабочие потоки, которые можно масштабировать до большого количества. Спасибо за ваш комментарий, чтобы напомнить об этом. 21.07.2011
  • @Behrooz: Если вам нужно обработать C10k или что-то в этом роде, потоки могут быть не лучшим способом сделать это. Вместо этого вы можете использовать что-то вроде асинхронного ввода-вывода (который впервые появится в библиотеке Java 7 NIO.2). 21.07.2011
    • Новые материалы
    Я хотел выучить язык программирования MVC4, но не мог выучить его раньше, потому что это выглядит сложно…
    Просто начните и учитесь самостоятельно Я хотел выучить язык программирования MVC4, но не мог выучить его раньше, потому что он кажется мне сложным, и я бросил его. Это в основном инструмент..
    Лицензии с открытым исходным кодом: руководство для разработчиков и создателей
    В динамичном мире разработки программного обеспечения открытый исходный код стал мощной парадигмой, способствующей сотрудничеству, инновациям и прогрессу, движимому сообществом. В основе..
    Объяснение документов 02: BERT
    BERT представил двухступенчатую структуру обучения: предварительное обучение и тонкая настройка. Во время предварительного обучения модель обучается на неразмеченных данных с помощью..
    Как проанализировать работу вашего классификатора?
    Не всегда просто знать, какие показатели использовать С развитием глубокого обучения все больше и больше людей учатся обучать свой первый классификатор. Но как только вы закончите..
    Работа с цепями Маркова, часть 4 (Машинное обучение)
    Нелинейные цепи Маркова с агрегатором и их приложения (arXiv) Автор : Бар Лайт Аннотация: Изучаются свойства подкласса случайных процессов, называемых дискретными нелинейными цепями Маркова..
    Crazy Laravel Livewire упростил мне создание электронной коммерции (панель администратора и API) [Часть 3]
    Как вы сегодня, ребята? В этой части мы создадим CRUD для данных о продукте. Думаю, в этой части я не буду слишком много делиться теорией, но чаще буду делиться своим кодом. Потому что..
    Использование машинного обучения и Python для классификации 1000 сезонов новичков MLB Hitter
    Чему может научиться машина, глядя на сезоны новичков 1000 игроков MLB? Это то, что исследует это приложение. В этом процессе мы будем использовать неконтролируемое обучение, чтобы..
    Для любых предложений по сайту: [email protected]