Цитата(LSD @ 9.4.2014, 19:03  ) | Ошибка говорит о том, что метод wait() должен вызываться потоком которых захватил монитор на объект (у которого вызыватся wait()). Но это все не важно, тут есть проблемы серьезней:
1. Непонятно причем тут семафоры, когда это типичный read-write lock.
2. Реализовать семафор самостоятельно без "нативной" поддержки нельзя. Или надо использовать synchronized или готовую реализацию из java.util.concurrent. |
Спасибо.
Да согласен, именно с этим и была проблема. Плюс проблема в растановке семафоров.
Вот переделанный рабочий код:
| Код |
public class MyProg {
public static void main(String[] args) {
Database myDB = new Database();
Reader reader1 = new Reader(1, myDB);
Reader reader2 = new Reader(2, myDB);
Reader reader3 = new Reader(3, myDB);
Reader reader4 = new Reader(4, myDB);
Reader reader5 = new Reader(5, myDB);
Writer writer1 = new Writer(1, myDB);
Writer writer2 = new Writer(2, myDB);
Writer writer3 = new Writer(3, myDB);
Writer writer4 = new Writer(4, myDB);
reader1.start();
reader2.start();
reader3.start();
reader4.start();
reader5.start();
writer1.start();
writer2.start();
writer3.start();
writer4.start();
}
}
class Reader extends Thread {
public Reader(int r, Database db) {
readerNum = r;
server = db;
}
public void run() {
int c;
for (int i = 1; i <= 3; i++) // It should be while (true)
{
napping();
System.err.println("reader " + readerNum + " wants to read.");
c = server.startRead();
System.err.println("reader " + readerNum + " is reading. Reader Count = " + c);
Database.something();
c = server.endRead();
}
}
public void napping() {
try {
sleep((int) (Math.random() * 5000));
} catch (InterruptedException e) {
}
}
private Database server;
private int readerNum;
}
class Writer extends Thread {
public Writer(int w, Database db) {
writerNum = w;
server = db;
}
public void run() {
for (int i = 1; i <= 3; i++) // It should be while (true)
{
napping();
System.err.println("writer " + writerNum + " wants to write.");
server.startWrite();
System.err.println("-------------- WRITER " + writerNum + " IS WRITING.");
Database.something();
System.err.println(" writer " + writerNum + " is done writing.");
server.endWrite();
}
}
public void napping() {
try {
sleep((int) (Math.random() * 5000));
} catch (InterruptedException e) {
}
}
private Database server;
private int writerNum;
}
class Database {
public Database() {
readerCount = 0;
semWriter = new Semaphore(1);
sem = new Semaphore(1);
}
public static void something() {
try {
Thread.sleep((int) (Math.random() * 5000));
} catch (InterruptedException e) {
}
}
public int startRead() {
sem.P();
if (readerCount == 0){
semWriter.P();
}
readerCount++;
sem.V();
return readerCount;
}
public int endRead() {
sem.P();
--readerCount;
System.err.println("Reader is done reading. Count = " + readerCount);
if (readerCount == 0){
semWriter.V(); // if I am the last reader tell all others
}
sem.V();
return readerCount;
}
public void startWrite() {
semWriter.P();
}
public void endWrite() {
semWriter.V();
}
private int readerCount; // the number of active readers
private Semaphore semWriter, sem;
}
class Semaphore
{
public Semaphore(int v)
{ value = v; }
public synchronized void P()
{ value--;
if (value < 0)
try
{wait();}
catch (InterruptedException e) {}
}
public synchronized void V()
{ ++value;
if (value<=0)
notify();
}
private int value;
}
|
Добавлено через 2 минуты и 5 секунд
| Цитата(Mirkes @ 9.4.2014, 22:33 ) | | По идее должно быть что-то вроде: Читатель семафору "Можно читать?", Семафор читателю "Можно", тогда стартует чтение. Правда при многопоточности нет гарантии, что между ответом семафора и собственно началом чтения не влезет кто-то еще. |
Согласен.
| Цитата(Mirkes @ 9.4.2014, 22:33 ) |
Для предотвращения такого конфликта, семафор в случае положительного ответа сначала блокирует доступ другим, а уже затем выдает ответ. |
Извините, не очень понятно как это можно сделать? |
