Я столкнулся с небольшой проблемой здесь. Я делаю параллельную программу на Java. Проблема в том, что 4 человека (студенты) пытаются получить доступ к принтеру, чтобы распечатать 5 документов. Но только один может напечатать одновременно (видимо) 5 документов. Когда они заканчивают, они уведомляют других о том, что они сделали, и другой поток получает доступ к ресурсу. У меня есть основной класс, студенческий класс и монитор (лазерный принтер), класс документов, который содержит информацию о документе, например (количество страниц, имя пользователя и т. д.) + несколько интерфейсов для принтера. Мне удалось успешно запустить потоки, но они не синхронизированы (взаимное исключение)
Итак, вопрос в том, как мне добиться взаимного исключения (чтобы только один человек мог одновременно распечатать свое количество документов)
Спасибо за поиск, время и подсказки :)
Основной класс
String S1Name = "bob";
String S2Name = "klara";
String S3Name = "John";
String S4Name = "Iga";
String T1Name = "Man";
String T2Name = "Woman";
final int NoOfDocs = 5;
ServicePrinter sp = new LaserPrinter();
ThreadGroup groupA = new ThreadGroup("Group A");
ThreadGroup groupB = new ThreadGroup("Group B");
Student student1 = new Student(sp,NoOfDocs,S1Name, groupA);
Student student2 = new Student(sp,NoOfDocs,S2Name, groupA);
Student student3 = new Student(sp,NoOfDocs,S3Name, groupA);
Student student4 = new Student(sp,NoOfDocs,S4Name, groupA);
TonerTechnician TT = new TonerTechnician(groupB);
PaperTechnician PT = new PaperTechnician(groupB);
/*
* Start Student Threads
*/
student1.start();
student2.start();
student3.start();
student4.start();
/*
* Start Technician threads
*/
TT.start();
PT.start();
Студенческий класс
private final ServicePrinter serviceprinter;
private final int NoOfDocs;
private final String Name;
private final ThreadGroup threadgroup;
public Student(ServicePrinter serviceprinter, int NoOfDocs, String Name, ThreadGroup threadgroup)
{
this.serviceprinter = serviceprinter;
this.NoOfDocs = NoOfDocs;
this.Name = Name;
this.threadgroup = threadgroup;
}
@Override
public void run()
{
/*
* each students prints 5 documents (different name and length)
*/
final LaserPrinter lp = new LaserPrinter();
//sleep from 1 to 5 sec random time
final Random random = new Random();
char[] chars = "abcdefghijklmnopqrstuvwxyz".toCharArray();
StringBuilder sb = new StringBuilder();
/*
* Create random document name 10 characters long
*/
for (int i = 0; i < 10; i++)
{
char c = chars[random.nextInt(chars.length)];
sb.append(c);
}
String docName = sb.toString();
/*
* print 5 documents (random sleep time between printing)
*/
for(int i = 0; i < NoOfDocs; i++)
{
try
{
Document coursework = new Document(Name,docName,random.nextInt(90)+10);
lp.printDocument(coursework);
Thread.sleep(random.nextInt(1000)+4000);
}
catch (InterruptedException ex)
{
Logger.getLogger(Student.class.getName()).log(Level.SEVERE, null, ex);
}
}
System.out.println("User: " + Name+ " completed printing");
Класс монитора
int tonerLevel = 500;
int paperLevel = 250;
private final String PrinterName = "HP";
private final String PrinterID = "LX-440";
private int CurrentPaperLevel;
private int CurrentTonerLevel;
private int NoOfDocsPrinted;
@Override
public synchronized void printDocument(Document document) {
System.out.println(document);
}
LaserPrinter
вместо общего объектаserviceprinter
. Если вы измените это, база на основе этогоprintDocument
изServicePrinter
будет синхронизирована, я думаю, это может сработать. - person Jose Renato   schedule 19.03.2013final LaserPrinter lp = new LaserPrinter();
в вашем методе запуска) - person assylias   schedule 19.03.2013printDocument
синхронизируется, если вы используете общий экземплярLaserPrinter
, будет гарантировано, что печать документа будет атомарной. - person Jose Renato   schedule 19.03.2013LaserPrinter
в какой-то точке программы, например основной класс, и передать его через экземплярыStudent
иTonerTechnician
, чтобы синхронизированные операции, такие какprintDocument
, могли выполняться только одним пользователем одновременно. Понятно? - person Jose Renato   schedule 21.03.2013