Skip to content

Commit

Permalink
Initial Commit
Browse files Browse the repository at this point in the history
Code from MapWriter version 2.0.3.
  • Loading branch information
daveyliam committed May 22, 2013
0 parents commit c959ee7
Show file tree
Hide file tree
Showing 40 changed files with 6,280 additions and 0 deletions.
22 changes: 22 additions & 0 deletions .gitattributes
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
# Auto detect text files and perform LF normalization
* text=auto

# Custom for Visual Studio
*.cs diff=csharp
*.sln merge=union
*.csproj merge=union
*.vbproj merge=union
*.fsproj merge=union
*.dbproj merge=union

# Standard to msysgit
*.doc diff=astextplain
*.DOC diff=astextplain
*.docx diff=astextplain
*.DOCX diff=astextplain
*.dot diff=astextplain
*.DOT diff=astextplain
*.pdf diff=astextplain
*.PDF diff=astextplain
*.rtf diff=astextplain
*.RTF diff=astextplain
215 changes: 215 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,215 @@
#################
## Eclipse
#################

*.pydevproject
.project
.metadata
bin/
tmp/
*.tmp
*.bak
*.swp
*~.nib
local.properties
.classpath
.settings/
.loadpath

# External tool builders
.externalToolBuilders/

# Locally stored "Eclipse launch configurations"
*.launch

# CDT-specific
.cproject

# PDT-specific
.buildpath


#################
## Visual Studio
#################

## Ignore Visual Studio temporary files, build results, and
## files generated by popular Visual Studio add-ons.

# User-specific files
*.suo
*.user
*.sln.docstates

# Build results

[Dd]ebug/
[Rr]elease/
x64/
build/
[Bb]in/
[Oo]bj/

# MSTest test Results
[Tt]est[Rr]esult*/
[Bb]uild[Ll]og.*

*_i.c
*_p.c
*.ilk
*.meta
*.obj
*.pch
*.pdb
*.pgc
*.pgd
*.rsp
*.sbr
*.tlb
*.tli
*.tlh
*.tmp
*.tmp_proj
*.log
*.vspscc
*.vssscc
.builds
*.pidb
*.log
*.scc

# Visual C++ cache files
ipch/
*.aps
*.ncb
*.opensdf
*.sdf
*.cachefile

# Visual Studio profiler
*.psess
*.vsp
*.vspx

# Guidance Automation Toolkit
*.gpState

# ReSharper is a .NET coding add-in
_ReSharper*/
*.[Rr]e[Ss]harper

# TeamCity is a build add-in
_TeamCity*

# DotCover is a Code Coverage Tool
*.dotCover

# NCrunch
*.ncrunch*
.*crunch*.local.xml

# Installshield output folder
[Ee]xpress/

# DocProject is a documentation generator add-in
DocProject/buildhelp/
DocProject/Help/*.HxT
DocProject/Help/*.HxC
DocProject/Help/*.hhc
DocProject/Help/*.hhk
DocProject/Help/*.hhp
DocProject/Help/Html2
DocProject/Help/html

# Click-Once directory
publish/

# Publish Web Output
*.Publish.xml
*.pubxml

# NuGet Packages Directory
## TODO: If you have NuGet Package Restore enabled, uncomment the next line
#packages/

# Windows Azure Build Output
csx
*.build.csdef

# Windows Store app package directory
AppPackages/

# Others
sql/
*.Cache
ClientBin/
[Ss]tyle[Cc]op.*
~$*
*~
*.dbmdl
*.[Pp]ublish.xml
*.pfx
*.publishsettings

# RIA/Silverlight projects
Generated_Code/

# Backup & report files from converting an old project file to a newer
# Visual Studio version. Backup files are not needed, because we have git ;-)
_UpgradeReport_Files/
Backup*/
UpgradeLog*.XML
UpgradeLog*.htm

# SQL Server files
App_Data/*.mdf
App_Data/*.ldf

#############
## Windows detritus
#############

# Windows image file caches
Thumbs.db
ehthumbs.db

# Folder config file
Desktop.ini

# Recycle Bin used on file shares
$RECYCLE.BIN/

# Mac crap
.DS_Store


#############
## Python
#############

*.py[co]

# Packages
*.egg
*.egg-info
dist/
build/
eggs/
parts/
var/
sdist/
develop-eggs/
.installed.cfg

# Installer logs
pip-log.txt

# Unit test / coverage reports
.coverage
.tox

#Translations
*.mo

#Mr Developer
.mr.developer.cfg
122 changes: 122 additions & 0 deletions BackgroundExecutor.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,122 @@
package mapwriter;

import java.util.LinkedList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;



/*
This class handles executing and managing 'tasks'.
A single background thread runs tasks in the sequence they are added (via addTask()).
A linked list FIFO queue of every unfinished task is processed every time the processTaskQueue method is called.
processTaskQueue checks the task at the front of the queue to see if the background thread has processed it.
If it the task is complete processTaskQueue calls the onComplete() method of the task and removes it from the queue.
If it is not complete the task is added to the front of the queue again.
In this way the tasks are always processed sequentially, in the order they were added to the queue.
Tasks are extensions of the base Task class.
There are two abstract methods which must be overwritten by the extending class.
void run()
Is executed in the background thread when the executor reaches this task.
void onComplete()
Is called by processTaskQueue() when the task is done (after the run method is complete).
This method runs in the main thread so is a good place to copy the results of the run() method.
The run() method of a task added to the queue is guaranteed to be run before the run() method of the next task
added. Likewise the onComplete() method of the first task is guaranteed to be run before the onComplete() of the second
task. However the run() method of any class added after a Task may be executed before the onComplete() method of
the earlier Task is called.
e.g. addTask(Task1)
addTask(Task2)
addTask(Task3)
may run in the order:
Task1.run()
Task2.run()
Task1.onComplete()
Task3.run()
Task2.onComplete()
Task3.onComplete()
*/

public class BackgroundExecutor {

private ExecutorService executor;
private LinkedList<Task> taskQueue;
public boolean closed = false;

public BackgroundExecutor() {
this.executor = Executors.newSingleThreadExecutor();
this.taskQueue = new LinkedList<Task>();
}

// add a task to the queue
public boolean addTask(Task task) {
if (!this.closed) {
Future<?> future = this.executor.submit(task);
task.setFuture(future);
this.taskQueue.add(task);
} else {
MwUtil.log("MwExecutor.addTask: error: cannot add task to closed executor");
}
return this.closed;
}

// Pop a Task entry from the task queue and check if the task's thread has finished.
// If it has completed then call onComplete for the task.
// If it has not completed then push the task back on the queue.
public boolean processTaskQueue() {
boolean processed = false;
Task task = this.taskQueue.poll();
if (task != null) {
if (task.isDone()) {
task.printException();
task.onComplete();
processed = true;
} else {
// put entry back on top of queue
this.taskQueue.push(task);
}
}
return !processed;
}

public boolean processRemainingTasks(int attempts, int delay) {
while ((this.taskQueue.size() > 0) && (attempts > 0)) {
if (this.processTaskQueue()) {
try {
Thread.sleep(delay);
} catch (Exception e) {
}
attempts--;
}
}
return (attempts <= 0);
}

public int tasksRemaining() {
return this.taskQueue.size();
}

public boolean close() {
boolean error = true;
try {
// stop accepting new tasks
this.executor.shutdown();
// process remaining tasks
this.processRemainingTasks(50, 5);
// should already be terminated, but just in case...
error = !this.executor.awaitTermination(10L, TimeUnit.SECONDS);
error = false;
} catch (InterruptedException e) {
MwUtil.log("error: IO task was interrupted during shutdown");
e.printStackTrace();
}
this.closed = true;
return error;
}
}
Loading

0 comments on commit c959ee7

Please sign in to comment.