VPF::[JAVA] Message-passing solution - Форум программистов

KatrinIceLand

Дата 11.9.2007, 21:49 (ссылка)

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

Загрузка ...

Бывалый

Профиль
Группа: Участник
Сообщений: 166
Регистрация: 16.3.2006

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

Write a message-passing solution to the Producer-Consumer problem in Java. The solution should be based on:

• Blocking send and receive operations, and
• On a Channel implemented as a bounded stack.

I have an exmaple:

//Message passing solution to the Producer-Consumer problem in Java with nonblocking send and
//receive operations.

Код


public interface Channel
{
  public abstract void send(Object item);
  public abstract Object receive();
}

import java.util.Vector;
public class MessageQueue implement Channel
{
  private Vector queue;
  public MessageQueue()
  {
    queue = new Vector();
   }

   //This implements a nonblocking send// I need to change this part of the program to a blocking send

   public void send(Object item)
   {
     queue.addElement(item);
    }

   //This implements a nonbloking receive// I need to change this to a blocking receive

   public Object receive()
   {
     if (queue.size() == 0)
         return null;
    else
         return queue.remove(0);
    }
}
Channel mailBox;

while (true)
{
   Date message = new Date();
   mailBox.send(message);
}

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

[... кто изобрел математику? А зачем?...

powerOn

Дата 11.9.2007, 23:48 (ссылка)

(голосов:1)

Загрузка ...

software saboteur

Профиль
Группа: Участник
Сообщений: 4367
Регистрация: 7.10.2005

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

You just need to add a "synchronized" word to the method declarations to implement blocking logic:

Код


public class MessageQueue implements Channel
{
  private final Vector queue;
  public MessageQueue()
  {
    queue = new Vector();
   }
   
   public synchronized void send(Object item)
   {
     queue.addElement(item);
   }

   public synchronized Object receive()
   {
     if (queue.size() == 0)
         return null;
    else
         return queue.remove(0);
    }
}

Цитата(KatrinIceLand @ 11.9.2007, 22:49

)

• On a Channel implemented as a bounded stack.

If necessary to limit the number of messages in the stack, you can use the next solution:

Код


class MessageQueue implements Channel
{
    private long maxSize = -1; // "-1" means unlimited.
    private final Vector queue;
    
    public MessageQueue()
    {
        queue = new Vector();
    }

    public synchronized void send(Object item)
    {
        if ((maxSize < 0) || (queue.size() < maxSize))
            queue.addElement(item);
    }

    public synchronized Object receive()
    {
        if (queue.size() == 0)
            return null;
        else
            return queue.remove(0);
    }

    public long getMaxSize()
    {
        return maxSize;
    }

    public void setMaxSize(long maxSize)
    {
        this.maxSize = maxSize;
    }
}

Это сообщение отредактировал(а) Guedda - 12.9.2007, 09:21

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

нет времени думать - нужно писать КОД!

KatrinIceLand

Дата 12.9.2007, 01:15 (ссылка)

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

Загрузка ...

Бывалый

Профиль
Группа: Участник
Сообщений: 166
Регистрация: 16.3.2006

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

PowerOn, thanks a lot!

Thats what I need smile

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

[... кто изобрел математику? А зачем?...

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