Lines Matching refs:concurrency
52 * Although this demo does allow for concurrency
77 public PollingServer(int concurrency) {
117 consumerThread < concurrency; consumerThread++ ) {
194 for (int cThread = 0; cThread < concurrency; cThread++ ) {
201 * main ... just check if a concurrency was specified
205 int concurrency;
208 concurrency = java.lang.Integer.valueOf(args[0]).intValue();
210 concurrency = Poller.getNumCPUs() + 1;
211 PollingServer server = new PollingServer(concurrency);
217 * the number of CPUs (or concurrency argument).