|
|
@ -1,12 +1,3 @@ |
|
|
|
/** |
|
|
|
* Modified version of HashedWheelScheduler specially for timeouts handling. |
|
|
|
* Difference: |
|
|
|
* - handling old timeout with same key after adding new one |
|
|
|
* fixes multithreaded problem that appears in highly concurrent non-atomic sequence cancel() -> schedule() |
|
|
|
* |
|
|
|
* (c) Alim Akbashev, 2015-02-11 |
|
|
|
*/ |
|
|
|
|
|
|
|
/** |
|
|
|
* Copyright 2012 Nikita Koksharov |
|
|
|
* |
|
|
@ -22,6 +13,14 @@ |
|
|
|
* See the License for the specific language governing permissions and |
|
|
|
* limitations under the License. |
|
|
|
*/ |
|
|
|
/** |
|
|
|
* Modified version of HashedWheelScheduler specially for timeouts handling. |
|
|
|
* Difference: |
|
|
|
* - handling old timeout with same key after adding new one |
|
|
|
* fixes multithreaded problem that appears in highly concurrent non-atomic sequence cancel() -> schedule() |
|
|
|
* |
|
|
|
* (c) Alim Akbashev, 2015-02-11 |
|
|
|
*/ |
|
|
|
|
|
|
|
package com.corundumstudio.socketio.scheduler; |
|
|
|
|
|
|
|