КДП/Лаб 1 2020 - Историја измена

Etfsibg: /* RegionBarrier.java */

2023-06-19T06:19:26Z

RegionBarrier.java

← Старија измена		Верзија на датум 19. јун 2023. у 08:19
Ред 424:		Ред 424:
	public boolean await(long timeout) {		public boolean await(long timeout) {
	synchronized (barrier) {		synchronized (barrier) {
	~~if (barrier.barrierPassed) {~~
	~~return true;~~
	}
	while (!barrier.barrierPassed) {		while (!barrier.barrierPassed) {
	long timeBefore = System.currentTimeMillis();		long timeBefore = System.currentTimeMillis();

2023-06-19T01:17:35Z

RegionBarrier.java

← Старија измена		Верзија на датум 19. јун 2023. у 03:17
Ред 387:		Ред 387:
	package kdpl12020;		package kdpl12020;

			// Jednokratna barijera.
	public class RegionBarrier implements Barrier {		public class RegionBarrier implements Barrier {

Ред 443:		Ред 444:

	@Override		@Override
			public void reset() {}

	}		}

2023-06-19T01:17:03Z

RegionBarrier.java

2023-06-19T01:15:16Z

Синхронизација

@@ Ред 379: / Ред 379: @@
+	}
+}
 </syntaxhighlight>

2023-06-18T23:58:29Z

SemaphoreBoundedBuffer.java

← Старија измена		Верзија на датум 19. јун 2023. у 01:58
Ред 126:		Ред 126:
	package kdpl12020;		package kdpl12020;

	~~import java.util.ArrayList;~~
	~~import java.util.List;~~
	import java.util.concurrent.Semaphore;		import java.util.concurrent.Semaphore;

	public class SemaphoreBoundedBuffer<T> implements BoundedBuffer<T> {		public class SemaphoreBoundedBuffer<T> implements BoundedBuffer<T> {

	private final ~~List<~~T> buffer;		private final T buffer[];
			private int readIndex;
			private int writeIndex;
			private int capacity;

	private final Semaphore mutexProducer;		private final Semaphore mutexProducer;
Ред 139:		Ред 140:
	private final Semaphore full;		private final Semaphore full;

			@SuppressWarnings("unchecked")
	public SemaphoreBoundedBuffer(int capacity) {		public SemaphoreBoundedBuffer(int capacity) {
	buffer = new ~~ArrayList<T>(~~capacity);		readIndex = writeIndex = 0;
			buffer = (T[]) new Object[capacity];
			this.capacity = capacity;

	mutexProducer = new Semaphore(1);		mutexProducer = new Semaphore(1);
Ред 153:		Ред 157:

	mutexProducer.acquireUninterruptibly();		mutexProducer.acquireUninterruptibly();
	buffer~~.add~~(~~data~~);		buffer[writeIndex] = data;
			writeIndex = (writeIndex + 1) % capacity;
	mutexProducer.release();		mutexProducer.release();

Ред 164:		Ред 169:

	mutexConsumer.acquireUninterruptibly();		mutexConsumer.acquireUninterruptibly();
	T data = buffer~~.remove~~(0);		T data = buffer[readIndex];
			readIndex = (readIndex + 1) % capacity;
	mutexConsumer.release();		mutexConsumer.release();

2023-06-18T23:05:13Z

Consumer.java

← Старија измена		Верзија на датум 19. јун 2023. у 01:05
Ред 479:		Ред 479:
	barrier.arrived();		barrier.arrived();
	selectedBarrier.await(0);		selectedBarrier.await(0);
	if (selected.~~get~~(id)) {		if (selected.getOrDefault(id, false)) {
	// Send data to the combiner.		// Send data to the combiner.
	for (Film film : films) {		for (Film film : films) {

2023-06-18T22:20:11Z

Printer.java

← Старија измена		Верзија на датум 19. јун 2023. у 00:20
Ред 569:		Ред 569:

	public class Printer extends Thread {		public class Printer extends Thread {
			private final static int NUMBER_OF_MILISECONDS_IN_ONE_SECOND = 1000;
	private final long interval;		private final long interval;
	private final ConcurrentMap<Integer, Integer> progress;		private final ConcurrentMap<Integer, Integer> progress;
Ред 585:		Ред 586:
	public void run() {		public void run() {
	while (true) {		while (true) {
	if (printerBarrier.await(interval * ~~1000~~)) {		if (printerBarrier.await(interval * NUMBER_OF_MILISECONDS_IN_ONE_SECOND)) {
	break;		break;
	}		}

2023-06-18T22:17:45Z

MonitorBarrier.java

← Старија измена		Верзија на датум 19. јун 2023. у 00:17
Ред 284:		Ред 284:
	} catch (InterruptedException e) {}		} catch (InterruptedException e) {}
	}		}
	return ~~currentCount == count~~;		return passed;
	}		}
	@Override		@Override

2023-06-18T22:01:36Z

Consumer.java

← Старија измена		Верзија на датум 19. јун 2023. у 00:01
Ред 479:		Ред 479:
	barrier.arrived();		barrier.arrived();
	selectedBarrier.await(0);		selectedBarrier.await(0);
	if (selected.~~getOrDefault~~(id~~, false~~)) {		if (selected.get(id)) {
	// Send data to the combiner.		// Send data to the combiner.
	for (Film film : films) {		for (Film film : films) {

2023-06-18T21:55:19Z

MonitorBarrier.java

← Старија измена		Верзија на датум 18. јун 2023. у 23:55
Ред 288:		Ред 288:
	@Override		@Override
	public synchronized void reset() {		public synchronized void reset() {
			notifyAll();
	currentCount = 0;		currentCount = 0;
	passed = false;		passed = false;