Как добиться эффективной модели потока для событий готовности ввода -вывода на выбираемых каналах с помощью селектора на ⇐ Android

[Anonymous]

Мы делимся нашим пониманием селектора и о том, как он работает ниже, то, что мы поняли, что, хотя некоторые аспекты селектора безопасны потока, реальное действие, в котором поток получает готовые события и обрабатывает их, сегодня только на потоке может вступить в действие в любое заданное время, что не позволяет нам достичь совпадения, чтобы добиться и обработать события, как они получают, чтобы они были достигнуты, чтобы они были достигнуты. Выше.

• Селектор может использоваться для мониторинга выбираемых каналов Java nio, когда канал готов к событию, которые можно прочитать, записать, принять, подключать (согласно зарегистрированному интересу), селектор сообщит нам. Получите готовое событие, используя API Register. /> ‘Selecter’ поддерживает три набора ключей. Набор ключей отбора, которые сняты из селектора.
  b. Отменен набор ключей не является безопасным потоком. < /Li>
  Зарегистрированный набор ключей:
  
  a. Набор ключей выбора, которые зарегистрировались в селекторе.
  b. Зарегистрированный набор клавиш безопасен. Набор ключей отбора, которые имеют хотя бы одну заинтересованную операцию в состоянии готового.
  b. Выбранный набор ключей не является безопасным потоком. < /Li>
  < /ul>
  
  Мы блокируем наш поток (network_io_in) на вызове Selecter Arteafct Select (), который будет разблокировать, когда хотя бы один из зарегистрированных каналов готов выполнять заинтересованные операции. /> < /ol>
  
  Сначала он итерации из -за отмененного набора ключей и освобождает ресурсы W.R.T Channel /Socket, которые сняты из селектора. SET. < /li>
  Примечание. Все эти шаги внутренне синхронизируются на селекторе, затем на наборе отмены и выбранного ключа. Выбранный набор ключей
  , который является частным элементом селектора.

Мы изнашиваемся над выбранным набором клавиш, определите, какая заинтересованная операция готова (чтение/запись/connect/accept) и выполняем, что io. мы. /> Наблюдение: < /li>
< /ol>

Все потоки заблокированы на вызове и вышли один за другим. /> Рассмотрение другого потока T2, которое заблокировано на вызове SELECT и выполняется на шаге, упоминается в 7.C, также работает на одном и том же выбранном наборе клавиш. {< /p>

Код: Выделить всё

while (true) {

println ("Thread " + Thread.currentThread().id + "blocked on select")

// Threads will get blocked on the select calls until there is at least one channel /socket which is ready.

selector.select ()

println ("Thread " + Thread.currentThread().id + "comes out of  select")
// Returns the reference of the selected key set.

val selected_key_set = selector.selectedKeys()

val iterator = selected_key_set.iterator()

println ("Thread " + Thread.currentThread().id +  “operating on the selected key set”)

while (iterator.hasNext()) {

// Extract the key (selection key object ) and increment the iterator.

val key = iterator.next()

// Remove the Seleciton Key object from the selected key set.

iterator.remove()

println (" Event receive corrsponding to descriptor id " + key.attachment() as Int)

when {

// Channel/Socket is ready for Receive.

key.isReadable -> {

…

// Buffer in which to copy the receive data.

var buffer = ByteBuffer.allocate(1024)

// Get the channel from Selection key object and call the receive.

(key.channel() as DatagramChannel).receive(buffer)

…

// Print the Receive data .

println ("Message Received: ${String(receivedData)}")

}

key.isWritable -> println("Write Ready")
}
}
}
< /code>
} < /p>
< /li>
< /ul>
Теперь добавление потока кода, где мы сделали синхронизацию нами. Какой канал/сокет прослушивается и зарегистрирован в селекторе. />  Поток, который выходит из вызова вызова вызова, скажем, T1 получает блокировку на selected_key_set, чья ссылка возвращается Selectedkeys () Call.  () Вызов.    while (true) {

println ("Thread " + Thread.currentThread().id + "blocked on select")

selector.select ()

println ("Thread " + Thread.currentThread().id + "comes out of  select")

val selected_key_set = selector.selectedKeys()
// Here we have synchronize on the selected_key_set which ensures that thread which are blocked on the select call will not be able to use it if another thread is already operating over it.

synchronized (selected_key_set) {

println ("Thread " + Thread.currentThread().id + "blocked on selected key set")

val iterator = selected_key_set.iterator()

while (iterator.hasNext()) {

val key = iterator.next()

println (" Event receive corrsponding to descriptor id " + key.attachment() as Int)

iterator.remove()
when {

key.isReadable -> {
counter++;
var buffer = ByteBuffer.allocate(1024)

(key.channel() as DatagramChannel).receive(buffer)
buffer.flip()
val receivedData = ByteArray(buffer.remaining())
buffer.get(receivedData)
println ("Recv Event Number: "+ counter)
println ("Message Received: ${String(receivedData)}")

}

key.isWritable -> println("Write Ready")
}
}
}
println ("Thread " + Thread.currentThread().id + "comes out of selected key set")

}

}
Здесь мы делаем синхронизацию на выбранном наборе ключей, когда мы выполняем обработку готовых событий (чтение/запись/принять/подключить), что позволяет только одному потоку работать за раз и блокирует другие потоки. обработка за раз, а другой будет ждать.

Подробнее здесь: https://stackoverflow.com/questions/790 ... s-on-selec