в 17:43, 31 мая 2010

2010-05-31T17:43:48Z

Admin: 1 версия

2010-05-31T14:23:08Z

1 версия

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

== CyclicBarrier: await() ==



<source lang="java">
import java.io.IOException;
import java.net.URL;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class MainClass {
CyclicBarrier barrier;
List<Result> results = new ArrayList<Result>();
static long timeConnect(String site) {
long start = System.currentTimeMillis();
try {
new URL(site).openConnection().connect();
} catch (IOException e) {
return -1;
}
return System.currentTimeMillis() - start;
}
void showResults() {
Collections.sort(results);
for (Result result : results)
System.out.printf("%-30.30s : %d\n", result.site, result.time);
System.out.println("------------------");
}
public void start(String[] args) {
Runnable showResultsAction = new Runnable() {
public void run() {
showResults();
results.clear();
}
};
barrier = new CyclicBarrier(args.length, showResultsAction);
for (final String site : args)
new Thread() {
public void run() {
while (true) {
long time = timeConnect(site);
results.add(new Result(time, site));
try {
barrier.await();
} catch (BrokenBarrierException e) {
return;
} catch (InterruptedException e) {
return;
}
}
}
}.start();
}
public static void main(String[] args) throws IOException {

new MainClass().start(new String[]{"www.jexp.ru","www.google.ru"});
}
}
class Result implements Comparable<Result> {
Long time;
String site;
Result(Long time, String site) {
this.time = time;
this.site = site;
}
public int compareTo(Result r) {
return time.rupareTo(r.time);
}
}

</source>



== new CyclicBarrier(int parties, Runnable barrierAction) ==



<source lang="java">
import java.io.IOException;
import java.net.URL;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class MainClass {
CyclicBarrier barrier;
List<Result> results = new ArrayList<Result>();
static long timeConnect(String site) {
long start = System.currentTimeMillis();
try {
new URL(site).openConnection().connect();
} catch (IOException e) {
return -1;
}
return System.currentTimeMillis() - start;
}
void showResults() {
Collections.sort(results);
for (Result result : results)
System.out.printf("%-30.30s : %d\n", result.site, result.time);
System.out.println("------------------");
}
public void start(String[] args) {
Runnable showResultsAction = new Runnable() {
public void run() {
showResults();
results.clear();
}
};
barrier = new CyclicBarrier(args.length, showResultsAction);
for (final String site : args)
new Thread() {
public void run() {
while (true) {
long time = timeConnect(site);
results.add(new Result(time, site));
try {
barrier.await();
} catch (BrokenBarrierException e) {
return;
} catch (InterruptedException e) {
return;
}
}
}
}.start();
}
public static void main(String[] args) throws IOException {

new MainClass().start(new String[]{"www.jexp.ru","www.google.ru"});
}
}
class Result implements Comparable<Result> {
Long time;
String site;
Result(Long time, String site) {
this.time = time;
this.site = site;
}
public int compareTo(Result r) {
return time.rupareTo(r.time);
}
}

</source>

← Предыдущая	Версия 17:43, 31 мая 2010
(нет различий)

Java by API/java.util.concurrent/CyclicBarrier - История изменений

в 17:43, 31 мая 2010

Admin: 1 версия