BogdanW3 у 19:22, 28. децембар 2023.

2023-12-28T19:22:43Z

← Старија измена		Верзија на датум 28. децембар 2023. у 21:22
Ред 14:		Ред 14:

	Изглед хијерархије фајлова:		Изглед хијерархије фајлова:
	.		.
	├── client		├── client
	│ └── Philosopher.java		│ └── Philosopher.java
	├── common		├── common
	│ └── Service.java		│ └── Service.java
	└── server		└── server
	├── RequestHandler.java		├── RequestHandler.java
	└── Server.java		└── Server.java

	==== <code>Philosopher.java</code> ====		==== <code>Philosopher.java</code> ====

K0v4c: Dodata stranica za lab2 rti 2023 kdp

2023-12-28T18:07:56Z

Dodata stranica za lab2 rti 2023 kdp

Нова страница

{{tocright}}

== Поставка ==

У зависности од групе било је потребно решити један од следеће два проблема.

1. Решити DiningPhilosopher проблем користећи <code>ExecutorService</code> и где је потребно да сервер враћа филозоферу информацију када му је дозвољено да једе. Користити <code>System.currentTimeMillis()</code> за дохватање времена и дозвоњено је користити <code>Future</code> и друге синхронизационе примитиве за решавање задатка.

2. TODO.

== Решење ==

Испод је дато решење за DiningPhilosophers.

Изглед хијерархије фајлова:
.
├── client
│ └── Philosopher.java
├── common
│ └── Service.java
└── server
├── RequestHandler.java
└── Server.java

==== <code>Philosopher.java</code> ====
<syntaxhighlight lang="java">
package client;

import common.Service;

public class Philosopher extends Thread{

public static final int NUM_OF_PHILOSOPHERS = 30;
public static int curr_id = 0;
public int id = 0;
public Service service;

public Philosopher(Service service) {
this.id = curr_id++;

this.service = service;
}

@Override
public void run() {

while(true) {
// think
try {
Thread.sleep((long) (Math.random() * 1000));
} catch (InterruptedException e) {
throw new RuntimeException(e);
}

this.service.eat(this.id);
}

}

public static void main(String[] args) {

Philosopher[] arr = new Philosopher[NUM_OF_PHILOSOPHERS];

Service service = new Service("localhost", 4001);

for(int i = 0; i < NUM_OF_PHILOSOPHERS; i++) {
arr[i] = new Philosopher(service);
}

for(int i = 0; i < NUM_OF_PHILOSOPHERS; i++) {
arr[i].start();
}

}
}
</syntaxhighlight>

==== <code>Service.java</code> ====
<syntaxhighlight lang="java">
package common;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class Service {

String host;
int port;

public Service(String host, int port) {
this.host = host;
this.port = port;
}

public void eat(int id) {

try (
Socket socket = new Socket(this.host, this.port);
BufferedReader buffered_reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter print_writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
) {

print_writer.println("eat"+"#"+id);

// Get the resource
String time = buffered_reader.readLine();
System.out.println("Filozofer sa id: " + id + " je dobio pristup u trenutku: " + time);

} catch (Exception e) {
e.printStackTrace();
}

}
}
</syntaxhighlight>

==== <code>RequestHandler.java</code> ====
<syntaxhighlight lang="java">
package server;

import java.io.*;
import java.net.Socket;
import java.util.Scanner;

public class RequestHandler extends Thread {

Socket sock;
Server server;

public RequestHandler(Socket sock, Server server) {
this.sock = sock;
this.server = server;
}

@Override
public void run() {

try (
Socket socket = this.sock;
BufferedReader buffered_reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter print_writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
) {

String in = buffered_reader.readLine();

String[] data = in.split("#");

String operation = data[0];
int id = Integer.parseInt(data[1]);

if ("eat".equalsIgnoreCase(operation)) {
server.test(id);
server.eat(buffered_reader, print_writer);
server.signal(id);
}

} catch (Exception e) {
e.printStackTrace();
}

}
}
</syntaxhighlight>

==== <code>Server.java</code> ====
<syntaxhighlight lang="java">
package server;

import java.io.BufferedReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Server {

ExecutorService pool;
final static int MAX_THREADS = 10;

public static final int NUM_OF_PHILOSOPHERS = 30;
int []forks;
int port;

public Server(int port) {
this.forks = new int[NUM_OF_PHILOSOPHERS];

for(int i = 0; i < NUM_OF_PHILOSOPHERS; i++) {
forks[i] = 2;
}

pool = Executors.newFixedThreadPool(MAX_THREADS);

this.port = port;
}

public synchronized void test(int id) {
int left = (id - 1 + NUM_OF_PHILOSOPHERS) % NUM_OF_PHILOSOPHERS;
int right = (id + 1 + NUM_OF_PHILOSOPHERS) % NUM_OF_PHILOSOPHERS;

while(forks[id] != 2) {
try {
wait();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}

forks[left]--;
forks[right]--;

}

public void eat(BufferedReader rd, PrintWriter pw) {
pw.println(System.currentTimeMillis());
}

public synchronized void signal(int id){
int left = (id - 1 + NUM_OF_PHILOSOPHERS) % NUM_OF_PHILOSOPHERS;
int right = (id + 1 + NUM_OF_PHILOSOPHERS) % NUM_OF_PHILOSOPHERS;
forks[left]++;
forks[right]++;

notifyAll();
}

public static void main(String[] args) {

Server server = new Server(4001);

try (
ServerSocket listener = new ServerSocket(server.port)
) {
while(true) {
Socket sock = listener.accept();

// new RequestHandler(sock, server).start();

server.pool.execute(new RequestHandler(sock, server));
}
} catch (Exception e) {
e.printStackTrace();
}

}
}

</syntaxhighlight>

[[Категорија:КДП]]
[[Категорија:Лабораторијске вежбе]]

КДП/Лаб 2 РТИ 2023 - Историја измена

BogdanW3 у 19:22, 28. децембар 2023.

K0v4c: Dodata stranica za lab2 rti 2023 kdp