Всем привет! Вообщем в java я новичок(совсем). Решил вот написать программку: Есть один поток процессов, который обслуживается одним процессором с одной очередью. Хочу сделать так, чтобы программа пихала процесс в очередь, а процессор брал и выполнял процессы из очереди. Вроде бы простая задачка, НО мне совсем не даётся. Прошу поделиться кодом, ссылками, чем угодно, что помогло бы решить задачу.
Собственно проблема именно с реализацией очереди( наверное
)
Вот что у меня есть:
Кликните здесь для просмотра всего текста
| Java |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
| public interface ISemaphore {
public void release();
}
//processor
public class CPU implements ISemaphore {
private int processorsCount=1;
private int allProcessCount=0,destroyedProcessCount=0;
private final Semaphore semaphore;
public int getAllProcessCount() {
return allProcessCount;
}
public int getDestroyedProcessCount() {
return destroyedProcessCount;
}
public CPU() {
this.semaphore=new Semaphore(this.processorsCount);
}
public CPU(int processorsCount) {
this.processorsCount=processorsCount;
this.semaphore=new Semaphore(this.processorsCount);
}
public void runProcess(CPUProcess process) {
allProcessCount++;
if (semaphore.tryAcquire()) {
process.start();
}
else {
destroyedProcessCount++;
process=null;
}
}
public void release() {
semaphore.release();
}
}
//process
public class CPUProcess extends Thread{
private ISemaphore semaphore;
private int runTime;
public CPUProcess(ISemaphore semaphore, int runTime) {
this.runTime=runTime;
this.semaphore=semaphore;
}
public void run() {
try {
Thread.sleep(runTime);
}
catch (InterruptedException e) {
System.err.println(e);
}
semaphore.release();
}
}
public class Main1 {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
CPU processors=new CPU();
try {
CPUProcess proc;
proc=new CPUProcess(processors,10);
processors.runProcess(proc);
Thread.sleep(100);
proc=new CPUProcess(processors,10);
processors.runProcess(proc);
proc=new CPUProcess(processors,10);
processors.runProcess(proc);
proc.join();
}
catch (InterruptedException e) {
System.err.println(e);
}
System.out.println("count: "+processors.getAllProcessCount());
System.out.println("kill: "+processors.getDestroyedProcessCount());
}
} |
|
) 
(
