[
https://issues.apache.org/jira/browse/IGNITE-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Dmitriev updated IGNITE-10250:
------------------------------------
Description:
Ignite Queue hangs after several read/write operations. Code to reproduce:
{code:java}
try (Ignite ignite = Ignition.start()) {
IgniteQueue<Integer> queue = ignite.queue("TEST_QUEUE", 1, new
CollectionConfiguration());
new Thread(() -> {
for (int i = 0;; i++) {
queue.put(i);
System.out.println("Put: " + i);
}
}).start();
new Thread(() -> {
for (int i = 0;; i++) {
queue.take();
System.out.println("Take: " + i);
}
}).start();
Thread.currentThread().join();
}
{code}
was:
Ignite Queue hangs after several read/write operations. Code to reproduce:
{noformat}
try (Ignite ignite = Ignition.start()) {
IgniteQueue<Integer> queue = ignite.queue("TEST_QUEUE", 1, new
CollectionConfiguration());
new Thread(() -> {
for (int i = 0;; i++) {
queue.put(i);
System.out.println("Put: " + i);
}
}).start();
new Thread(() -> {
for (int i = 0;; i++) {
queue.take();
System.out.println("Take: " + i);
}
}).start();
Thread.currentThread().join();
{noformat}
> Ignite Queue hangs after several read/write operations
> ------------------------------------------------------
>
> Key: IGNITE-10250
> URL: https://issues.apache.org/jira/browse/IGNITE-10250
> Project: Ignite
> Issue Type: Bug
> Components: data structures
> Affects Versions: 2.7
> Reporter: Anton Dmitriev
> Priority: Major
>
> Ignite Queue hangs after several read/write operations. Code to reproduce:
> {code:java}
> try (Ignite ignite = Ignition.start()) {
> IgniteQueue<Integer> queue = ignite.queue("TEST_QUEUE", 1, new
> CollectionConfiguration());
> new Thread(() -> {
> for (int i = 0;; i++) {
> queue.put(i);
> System.out.println("Put: " + i);
> }
> }).start();
> new Thread(() -> {
> for (int i = 0;; i++) {
> queue.take();
> System.out.println("Take: " + i);
> }
> }).start();
> Thread.currentThread().join();
> }
> {code}
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
