com.alexkasko.unsafe.offheapstruct

Class OffHeapStructSorterInt.Worker

java.lang.Object

com.alexkasko.unsafe.offheapstruct.OffHeapStructSorterInt.Worker

All Implemented Interfaces:

Callable<Void>

Enclosing class:

OffHeapStructSorterInt

private static class OffHeapStructSorterInt.Worker
extends Object
implements Callable<Void>

Worker, sorts part of the collection

Field Summary

Fields

Modifier and Type	Field and Description
private OffHeapStructCollection	a
private int	keyOffset
(package private) long	left
private byte[]	pe1
private byte[]	pe2
private byte[]	pe3
private byte[]	pe4
private byte[]	pe5
private byte[]	pi
private byte[]	pj
(package private) long	right

Constructor Summary

Constructors

Modifier	Constructor and Description
private	OffHeapStructSorterInt.Worker(OffHeapStructCollection a, long left, long right, int keyOffset, byte[] pi, byte[] pj, byte[] pe1, byte[] pe2, byte[] pe3, byte[] pe4, byte[] pe5) Private constructor

Method Summary

Methods

Modifier and Type	Method and Description
Void	call()
private static void	invokeAndWait(ExecutorService executor, List<OffHeapStructSorterInt.Worker> workers) Helper method to invoke and wait

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

a

private final OffHeapStructCollection a

left

final long left

right

final long right

keyOffset

private final int keyOffset

pi

private final byte[] pi

pj

private final byte[] pj

pe1

private final byte[] pe1

pe2

private final byte[] pe2

pe3

private final byte[] pe3

pe4

private final byte[] pe4

pe5

private final byte[] pe5

Constructor Detail

OffHeapStructSorterInt.Worker

private OffHeapStructSorterInt.Worker(OffHeapStructCollection a,
                             long left,
                             long right,
                             int keyOffset,
                             byte[] pi,
                             byte[] pj,
                             byte[] pe1,
                             byte[] pe2,
                             byte[] pe3,
                             byte[] pe4,
                             byte[] pe5)

Private constructor

Parameters:

a - collection

left - start sort index

right - end sort index

keyOffset - sort key offset

pi - sort buffer

pj - sort buffer

pe1 - sort buffer

pe2 - sort buffer

pe3 - sort buffer

pe4 - sort buffer

pe5 - sort buffer

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

invokeAndWait

private static void invokeAndWait(ExecutorService executor,
                 List<OffHeapStructSorterInt.Worker> workers)

Helper method to invoke and wait

Parameters:

executor - executor instance

workers - workers list