VPF::ThreadPull - Форум программистов

altarasjuk

Дата 16.5.2003, 17:16 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 331
Регистрация: 7.5.2003
Где: Харьков

Репутация: нет
Всего: 1

Привет!

Помогите, плиз, найти нормальный класс для тред-пулла, или подскажите как его писать, а то у меня получается как-то коряво.

--------------------

Правда - изобретение маньяков: колет глаза и режет уши.

DarkDS

Дата 16.5.2003, 17:24 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник Клуба
Сообщений: 748
Регистрация: 6.5.2003
Где: Таллинн, Эстония

Репутация: 11
Всего: 16

В каком виде ты хочешь этот пул видеть... Поподробнее...

AntonSaburov

Дата 16.5.2003, 18:15 (ссылка)

(нет голосов)

Загрузка ...

Штурман

Профиль
Группа: Модератор
Сообщений: 5658
Регистрация: 2.7.2002
Где: Санкт-Петербург

Репутация: 51
Всего: 118

Да и что у тебя получается тоже неплохо было бы написать/

--------------------

Мои проекты для Винграда

altarasjuk

Дата 16.5.2003, 18:52 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 331
Регистрация: 7.5.2003
Где: Харьков

Репутация: нет
Всего: 1

Цитата

В каком виде ты хочешь этот пул видеть... Поподробнее...

В виде исходников или доки, как его делать.

Цитата

Да и что у тебя получается тоже неплохо было бы написать

А получается там примерно так:

Код


public class ConnectionThreadPull implements ConnectionThreadFreeEventListener {
  private static final int DEF_THREADS_COUNT = 1000;

  private ConnectionThread reservedThread;
  private LinkedList freeThreads = new LinkedList();
  private LinkedList inUseThreads = new LinkedList();

  private Server server;

  private List threadConnectionReadyListeners = Collections.synchronizedList(new LinkedList());

  public ConnectionThreadPull(Server server) {
    this(server, DEF_THREADS_COUNT);
  }

  public ConnectionThreadPull(Server server, int threadCount) {
    this.server = server;
    reservedThread = new ConnectionThread(server, true);
    reservedThread.addConnectionThreadFreeEventListener(this);
    for (int i = 0; i < threadCount; i++) {
      ConnectionThread ct = new ConnectionThread(server, false);
      ct.addConnectionThreadFreeEventListener(this);
      freeThreads.add(ct);
    }
  }

  public void addConnectionThreadReadyListener(ConnectionThreadReadyEventListener l) {
    threadConnectionReadyListeners.add(l);
  }

  private void generateConnectionThreadReadyEvent(ConnectionThread ct) {
    ConnectionThreadReadyEvent e = new ConnectionThreadReadyEvent(ct);
    for (Iterator i = threadConnectionReadyListeners.iterator(); i.hasNext();) {
      ((ConnectionThreadReadyEventListener) i.next()).threadReady(e);
    }
  }

  synchronized public ConnectionThread getFreeConnectionThread() {
    if (freeThreads.isEmpty()) {
      return null;
    }
    ConnectionThread ct = (ConnectionThread) freeThreads.getFirst();
    markAsUse(ct);
    return ct;
  }

  synchronized public ConnectionThread getReservedConnectionThread() {
    ConnectionThread ct = getFreeConnectionThread();
    if (ct != null) {
      return ct;
    }
    if (reservedThread.isFree()) {
      return reservedThread;
    }
    return null;
  }

  private void markAsUse(ConnectionThread ct) {
    if (ct != reservedThread) {
      freeThreads.remove(ct);
      inUseThreads.addLast(ct);
    }
  }

  private void markAsFree(ConnectionThread ct) {
    if (ct != reservedThread) {
      inUseThreads.remove(ct);
      freeThreads.addLast(ct);
    }
  }

  public void threadFree(ConnectionThreadFreeEvent e) {
    markAsFree(e.getConnectionThread());
    generateConnectionThreadReadyEvent(e.getConnectionThread());
  }
}

На мой взгляд это очень уродски и сложно

. Должен жеж быть более человеческий путь.

--------------------

Правда - изобретение маньяков: колет глаза и режет уши.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »