VPF::Работа со стеками - Форум программистов

barin_Student

Дата 5.12.2007, 15:57 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 488
Регистрация: 10.8.2007
Где: Казахстан , Алмат ы

Репутация: 1
Всего: 2

В продолжение темы про очередь:
У меня берется из очереди последнее то что туда положилось , вот полностью пример:

Код


//так я ложу
public static LinkedBlockingQueue<submit> BeelineQueue = new LinkedBlockingQueue<submit>();
////
 if(sessionBeeline.isOpened())//сверка коннекта
 {  
        //бла бла                                                                
 }
 else
 {
        BeelineQueue.offer(submit);// BeelineQueue 
  }

счас покажу как забираю:

Код


   submit = BeelineQueue.poll();

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

--------------------

Нехорошо блин!!!

LSD

Дата 5.12.2007, 16:13 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Код


import java.util.concurrent.LinkedBlockingQueue;

public class Test
{
  private static LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>();
  private static boolean running = true;

  public static void main(String[] args) throws Exception
  {
    Thread producer = new Thread(new Producer());
    Thread consumer = new Thread(new Consumer());
    producer.start();
    consumer.start();
    Thread.sleep(10 * 1000);
    running = false;
  }

  private static class Producer implements Runnable
  {
    private int count = 0;

    public void run()
    {
      while(running)
      {
        queue.offer(Integer.toString(count++));
        try
        {
          Thread.sleep(500);
        }
        catch(InterruptedException e)
        {
          //do nothing
        }
      }
      queue.offer(Integer.toString(count++));
    }
  }

  private static class Consumer implements Runnable
  {
    public void run()
    {
      while(running)
      {
        try
        {
          System.out.println("take = " + queue.take());
        }
        catch(InterruptedException e)
        {
          //do nothing
        }
      }
    }
  }
}

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »