com.unister.semweb.drums.sync
Class SyncThread<Data extends AbstractKVStorable>

java.lang.Object
  com.unister.semweb.drums.sync.SyncThread<Data>

Type Parameters:

Data - an implementation of AbstractKVStorable, e.g. GeneralStorable

All Implemented Interfaces:

java.lang.Runnable

public class SyncThread<Data extends AbstractKVStorable>
extends java.lang.Object
implements java.lang.Runnable

An instance of a SyncThread. Synchronizes a Bucket with the file system.

Author:

Martin Nettling

Constructor Summary

SyncThread(SyncManager<Data> syncManager, Bucket<Data> bucket, java.util.Set<Bucket<Data>> actualProcessingBuckets, ISynchronizerFactory<Data> synchronizerFactory, DRUMSParameterSet<Data> gp)
Constructor.

Method Summary

void	run() runs synchronization of a particular Bucket

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncThread

public SyncThread(SyncManager<Data> syncManager,
                  Bucket<Data> bucket,
                  java.util.Set<Bucket<Data>> actualProcessingBuckets,
                  ISynchronizerFactory<Data> synchronizerFactory,
                  DRUMSParameterSet<Data> gp)

Constructor. The given Bucket will be processed.

Parameters:

syncManager -

bucket - the Bucket to synchronize to HDD

actualProcessingBuckets - pointer to a set of buckets in process

synchronizerFactory - an implementation of ISynchronizerFactory. This factory is used for instantiating a Synchronizer. The latter is responsible for writing the Bucket to its corresponding file to disk

gp -

Method Detail

run

public void run()

runs synchronization of a particular Bucket

Specified by:

run in interface java.lang.Runnable