Embedded Files
Постановка задачи: Реализовать заданную модель, используя потоки для работы объектов.
Варианты моделей:
Паттерн и задача Производитель/Потребитель (Produser/Consumer)
Паттерн и задача Производитель/Потребитель (Produser/Consumer)
процесс-производитель ( producer ) генерирует в некотором буфере информацию, которая используется процессом-потребителем ( consumer ).
Producer (Поставщик) - это некоторый поток, который генерирует “задания” и складывает их в очередь Queue.
Consumer (Потребитель) - это поток, который берет задания из очереди, выполняет и отправляет результаты туда, куда нужно.
Очередь Queue (очередь продуктов) - это ограниченный буфер заданий с заранее заданной вместимостью.
Методические указания к выполнению
Методические указания к выполнению
Пример реализации взаимодействия Поставщика и Потребителя:
class Q{
int num;
boolean vs=false;
synchronized int get (){
while(!vs)
try{
wait();
}
catch (Exception e)
{
System.out.println("Excepton occurs at : "+e);
}
System.out.println("get" +num);
try
{
Thread.sleep(1000);
}
catch (Exception e)
{
System.out.println("Excepton occurs at : "+e);
}
vs=false;
notify();
return num;
}
synchronized int put(int num)
{
if (vs)
try
{
wait();
}
catch (Exception e)
{
System.out.println("Excepton occur at : "+e);
}
this.num=num;
vs=true;
System.out.println("put"+num);
try
{
Thread.sleep(1000);
}
catch (Exception e)
{
System.out.println("Excepton occur at : "+e);
}
notify();
return num;
}
}
class Producer implements Runnable
{
Thread1 t;
Producer(Thread1 t)
{
this.t=t;
new Thread(this,"Producer").start();
}
public void run()
{
int x=0;
int i = 0;
while (x<10)
{
t.put(i++);
x++;
}
}
}
class Consumer implements Runnable
{
Thread1 t;
Consumer(Thread1 t)
{
this.t=t;
new Thread(this,"Consumer").start();
}
public void run()
{
int x=0;
while (x<10)
{
t.get();
x++;
}
}
}
Для создания очереди см. Решение проблем
Решение проблемы Поставщик-Потребитель.pdfGoogle Sites
Report abuse